把map之前的repartition()调大,感觉屡试不爽~~
dataframe.repartition(10000).rdd.map(row => { //...
上一篇 03Linux查看端口是否被占用-没有自己的Linux服务器,网页上练习Linux命令
下一篇 [hadoop] 各节点职责| checkpoint |安全模式 |读写流程|小文件|安全模式
版权所有 (c)2021-2022 MSHXW.COM
ICP备案号:晋ICP备2021003244-6号