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