錯誤日志如下 spark：Exception in connection from /192.168.40.56:46550 java.io.IOException:Connection reset by peer 網上百度了很多 沒解決 最後發現是自己代碼問題 spark：Exception in connection from /192.168.40.56:46550 java.io.IOException:Connection reset by peer 去掉coalesce就好了或是把分區數調大一點 原因如下： spark：Exception in connection from /192.168.40.56:46550 java.io.IOException:Connection reset by peer
