问题

如题

原因

spark.dirver.maxResultSize参数默认为1024兆,所以会有限制

解决方法

在python脚本最上面添加如下配置即可

from pyspark.sql import SparkSession

spark = SparkSession \
    .builder \
    .appName("Python Spark SQL basic example") \
    .config("spark.memory.fraction", 0.8) \
    .config("spark.executor.memory", "14g") \
    .config("spark.driver.memory", "12g") \
    .config("spark.sql.shuffle.partitions", "800") \
    .config("spark.driver.maxResultSize", "0") \
    .getOrCreate()
Logo

腾讯云面向开发者汇聚海量精品云计算使用和开发经验,营造开放的云计算技术生态圈。

更多推荐