You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by "Dheeraj Panangat (Jira)" <ji...@apache.org> on 2022/10/28 11:56:00 UTC
[jira] [Created] (HUDI-5103) Does not work with Azure Data lake Gen2
Dheeraj Panangat created HUDI-5103:
--------------------------------------
Summary: Does not work with Azure Data lake Gen2
Key: HUDI-5103
URL: https://issues.apache.org/jira/browse/HUDI-5103
Project: Apache Hudi
Issue Type: Bug
Reporter: Dheeraj Panangat
Unable to use Hudi with Flink for Azure Data Lake
It tries to look for
{code:java}
Caused by: Configuration property <datalakeaccount>.dfs.core.windows.net not found.
at org.apache.hadoop.fs.azurebfs.AbfsConfiguration.getStorageAccountKey(AbfsConfiguration.java:372)
at org.apache.hadoop.fs.azurebfs.AzureBlobFileSystemStore.initializeClient(AzureBlobFileSystemStore.java:1133)
at org.apache.hadoop.fs.azurebfs.AzureBlobFileSystemStore.<init>(AzureBlobFileSystemStore.java:174) {code}
Following properties are specified when running the Flink code :
{code:java}
"fs.azure.account.auth.type": "OAuth",
"fs.azure.account.oauth.provider.type": "org.apache.hadoop.fs.azurebfs.oauth2.ClientCredsTokenProvider",
"fs.azure.account.oauth2.client.id": "<appId>",
"fs.azure.account.oauth2.client.secret": "<clientSecret>",
"fs.azure.account.oauth2.client.endpoint": "https://login.microsoftonline.com/<tenant>/oauth2/token",
"fs.azure.createRemoteFileSystemDuringInitialization": "true" {code}
as per document : [Microsoft Azure Spark to Data Lake Gen2|https://learn.microsoft.com/en-us/azure/storage/blobs/data-lake-storage-use-databricks-spark]
In AWS it works because it takes the credentials from the environment, but in Azure it needs to get it from config, which does not reach till the point where the FileSystem is initialized.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)