azure - Spark, wasb and Jetty 11
问题描述
When running Pyspark 3.1.1 with zulu11.45.27-ca-jdk11.0.10-win_x64 and trying to access Azure wasbs://container@store.blob.core.windows.net using hadoop-azure-3.2.2.jar jetty-util-11.0.1.jar jetty-util-ajax-11.0.1.jar
I get the following error:
py4j.protocol.Py4JJavaError: An error occurred while calling o49.csv.
: java.lang.NoSuchMethodError: 'java.util.Properties org.eclipse.jetty.util.log.Log.getProperties()'
at org.apache.hadoop.fs.azure.AzureNativeFileSystemStore.createPermissionJsonSerializer(AzureNativeFileSystemStore.java:410)
at org.apache.hadoop.fs.azure.AzureNativeFileSystemStore.<clinit>(AzureNativeFileSystemStore.java:314)
at org.apache.hadoop.fs.azure.NativeAzureFileSystem.createDefaultStore(NativeAzureFileSystem.java:1443)
at org.apache.hadoop.fs.azure.NativeAzureFileSystem.initialize(NativeAzureFileSystem.java:1368)
at org.apache.hadoop.fs.FileSystem.createFileSystem(FileSystem.java:3303)
at org.apache.hadoop.fs.FileSystem.access$200(FileSystem.java:124)
at org.apache.hadoop.fs.FileSystem$Cache.getInternal(FileSystem.java:3352)
at org.apache.hadoop.fs.FileSystem$Cache.get(FileSystem.java:3320)
at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:479)
at org.apache.hadoop.fs.Path.getFileSystem(Path.java:361)
Any help would be appreciated. Thanks
解决方案
推荐阅读
- java - 第一个对象未添加到 arraylist
- java - 如何在 API 26 中添加音乐播放器通知
- c# - 如何从头开始为硒测试创建自定义 HTML 报告
- azure-active-directory - 使用 AAD 为用户创建角色
- git - 命令行中的“Git add”未反映在 Visual Studio 2013 中
- python - Airflow + Cluster + Celery + SQS - Airflow Worker:“Hub”对象没有属性“_current_http_client”
- python - 当您输入变量名并希望它是一个整数以供以后计算时,如何使用输入函数?
- firebase - Firebase 用户已删除,但仍在设备上登录
- html - 如何在svg中创建一个椭圆
- c++ - 如何使用 uncrustify 缩进连续的函数参数?