【问题标题】:Why apache spark throw an exception when a try to get an spark configuration为什么 apache spark 在尝试获取 spark 配置时会抛出异常
【发布时间】:2021-10-09 15:17:24
【问题描述】:

当我尝试这样做时:

SparkConf conf = new SparkConf().setAppName("SparkUnitTest").setMaster("local[*]");
SparkSession sparkSession = SparkSession
                .builder()
                .config(conf)
                .getOrCreate();

JavaSparkContext sparkContext = JavaSparkContext.fromSparkContext(sparkSession.sparkContext());
sparkContext.getConf().get("spark.files.maxPartitionBytes")

我收到此错误:

java.util.NoSuchElementException: spark.files.maxPartitionBytes

【问题讨论】:

  • 因为设置其实是spark.**sql**.files.maxPartitionBytes?
  • 可以先添加你的代码吗?
  • 是的,已添加代码

标签: java apache-spark configuration


【解决方案1】:

您要查找的配置属性是:

spark.sql.files.maxPartitionBytes

而不是:

spark.files.maxPartitionBytes

spark sql performance tuning查看更多详情

【讨论】:

【解决方案2】:

查看 Spark 属性

“位于 http://:4040 的应用程序 Web UI 在“环境”选项卡中列出了 Spark 属性。这是一个有用的地方,可以检查以确保您的属性已正确设置。请注意,只有值通过 spark-defaults.conf、SparkConf 或命令行显式指定会出现对于所有其他配置属性,您可以假设使用默认值。"

https://spark.apache.org/docs/3.1.1/configuration.html#spark-properties

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2021-12-08
    • 2016-05-26
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2021-09-21
    • 2012-08-13
    • 2017-04-22
    相关资源
    最近更新 更多