raymund -磚

raymund · 11-03-2021

使用磚火花的提交工作,設置新的cluster1]“spark_version”:“8.2.x-scala2.12”= >好的,作品fine2]“spark_version”:“9.1.x-scala2.12”= >失敗,在線程errorsException . lang的“主要”。ExceptionInInitializerError com.databricks…

raymund · 11-10-2021

這是解決通過添加以下spark_conf(不是通過——conf)“spark.hadoop.fs.file。impl”:“org.apache.hadoop.fs。LocalFileSystem例子:- - - - - -“new_cluster ": {:“spark_version 9.1.x-scala2.12”……" spark_conf ": {“輕…

raymund · 11-09-2021

附加信息:使用磚spark-submit api pyspark " spark_submit_task ": {“參數”:[”——包”、“org.apache.spark: spark-sql-kafka-0-10_2.12:3.0.1 ....

raymund · 11-08-2021

@Piper威爾遜我刪除了評論,其工作。9.1問題仍然存在。卡夫卡流罐不存在。它拋出錯誤時卡夫卡流罐和卡夫卡pyspark代碼流不提供使用。當卡夫卡流……

磚

用戶數據

用戶活動

為什麼添加包org.apache.spark: spark-sql-kafka-0-10_2.12:3.0.1在運行時9.1.x-scala2.12失敗,但成功使用運行時8.2.x-scala2.12 ?

再保險:為什麼添加運行時包的org.apache.spark: spark-sql-kafka-0-10_2.12:3.0.1失敗9.1.x-scala2.12但成功使用運行時8.2.x-scala2.12嗎?

再保險:為什麼添加運行時包的org.apache.spark: spark-sql-kafka-0-10_2.12:3.0.1失敗9.1.x-scala2.12但成功使用運行時8.2.x-scala2.12嗎?

再保險:為什麼添加運行時包的org.apache.spark: spark-sql-kafka-0-10_2.12:3.0.1失敗9.1.x-scala2.12但成功使用運行時8.2.x-scala2.12嗎?