无法访问Azure数据湖存储Gen1

使用防火墙连接Databricks后Azure数据湖存储Gen

写由亚当巴夫拉卡

2022年12月9日

问题

ADLSGen1连接器访问ADLS时出错失败

328 format(target_id, ".", name), value) 329 else: 330 raise Py4JError(Py4JJavaError:  An error occurred while calling o196.parquet.: java.lang.RuntimeException:  Could not find ADLS Token at com.databricks.backend.daemon.data.client.adl.AdlCredentialContextTokenProvider$$anonfun$get Token$1.apply(AdlCredentialContextTokenProvider.scala:18)  at com.databricks.backend.daemon.data.client.adl.AdlCredentialContextTokenProvider$$anonfun$get  Token$1.apply(AdlCredentialContextTokenProvider.scala:18)  at scala.Option.getOrElse(Option.scala:121)  at com.databricks.backend.daemon.data.client.adl.AdlCredentialContextTokenProvider.getToken(AdlCredentialContextTokenProvider.scala:18)  at com.microsoft.azure.datalake.store.ADLStoreClient.getAccessToken(ADLStoreClient.java:1036)  at com.microsoft.azure.datalake.store.HttpTransport.makeSingleCall(HttpTransport.java:177)  at com.microsoft.azure.datalake.store.HttpTransport.makeCall(HttpTransport.java:91)  at com.microsoft.azure.datalake.store.Core.getFileStatus(Core.java:655)  at com.microsoft.azure.datalake.store.ADLStoreClient.getDirectoryEntry(ADLStoreClient.java:735)  at com.microsoft.azure.datalake.store.ADLStoreClient.getDirectoryEntry(ADLStoreClient.java:718)  at com.databricks.adl.AdlFileSystem.getFileStatus(AdlFileSystem.java:423)  at org.apache.hadoop.fs.FileSystem.exists(FileSystem.java:1426)  at org.apache.spark.sql.execution.datasources.InsertIntoHadoopFsRelationCommand.run(InsertIntoHadoopFsRelationCommand.scala:94)

因果

ADLSGen1连接器已知问题ADLS Gen1启动后不支持连接

求解

使用ADLSGen2取而代之

文章有帮助吗