1 个回答

这里可以直接在应用程序里面进行修改,也就是在sparkconf里面进行设置,示例如下:
session.conf.set("spark.sql.shuffle.partitions",30)
发布于:3个月前 (12-14)
我来回答
您需要 登录 后回答此问题!
这里可以直接在应用程序里面进行修改,也就是在sparkconf里面进行设置,示例如下:
session.conf.set("spark.sql.shuffle.partitions",30)