【问题标题】:How to set pivotMaxValues in pyspark?如何在pyspark中设置pivotMaxValues?
【发布时间】:2017-03-22 06:52:48
【问题描述】:

我正在尝试旋转具有超过 10000 个不同值的列。 Spark 中最大不同值的默认限制为 10000,我收到此错误

数据透视列 COLUMN_NUM_2 有超过 10000 个不同的值,这可能表示错误。如果这是有意为之,请将 spark.sql.pivotMaxValues 至少设置为数据透视列的不同值的数量

如何在 PySpark 中进行设置?

【问题讨论】:

    标签: pyspark pyspark-sql


    【解决方案1】:

    您必须在 Spark 解释器中添加/设置此参数。

    我在 EMR (AWS) 集群上使用 Zeppelin 笔记本,出现与您相同的错误消息,并且在我在解释器中添加参数后它工作正常。

    希望这会有所帮助...

    【讨论】:

    • 我在启动 Spark 集群之前通过设置解决了这个问题。 KEY 是 spark.sql.pivotMaxValues,我已将 VALUE 设置为 100000
    • 您能否详细说明您是如何设置该参数值的?是在火花上下文调用期间吗?等
    猜你喜欢
    • 2016-10-31
    • 2020-06-27
    • 2015-12-27
    • 2019-11-30
    • 1970-01-01
    • 2015-05-04
    • 2015-09-05
    • 2020-12-05
    • 1970-01-01
    相关资源
    最近更新 更多