|
@@ -76,7 +76,7 @@ def get_default_abfs_url():
|
|
|
|
|
|
|
|
def get_default_abfs_fs():
|
|
def get_default_abfs_fs():
|
|
|
default_fs = core_site.get_default_fs()
|
|
default_fs = core_site.get_default_fs()
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
if default_fs:
|
|
if default_fs:
|
|
|
return default_fs
|
|
return default_fs
|
|
|
else:
|
|
else:
|
|
@@ -146,9 +146,9 @@ ABFS_CLUSTERS = UnspecifiedConfigSection(
|
|
|
each=ConfigSection(
|
|
each=ConfigSection(
|
|
|
help="Information about a single ABFS cluster",
|
|
help="Information about a single ABFS cluster",
|
|
|
members=dict(
|
|
members=dict(
|
|
|
- FS_DEFAULTFS=Config("fs_defaultfs", help="abfss://<container_name>@<account_name>.dfs.core.windows.net", type=str, default=None),
|
|
|
|
|
|
|
+ FS_DEFAULTFS=Config("fs_defaultfs", help="abfs://<container_name>@<account_name>.dfs.core.windows.net", type=str, default=None),
|
|
|
WEBHDFS_URL=Config("webhdfs_url",
|
|
WEBHDFS_URL=Config("webhdfs_url",
|
|
|
- help="https://<container_name>@<account_name>.dfs.core.windows.net",
|
|
|
|
|
|
|
+ help="https://<account_name>.dfs.core.windows.net",
|
|
|
type=str, default=None),
|
|
type=str, default=None),
|
|
|
)
|
|
)
|
|
|
)
|
|
)
|