Exception in thread "main" org.apache.spark.SparkException: org.apache.spark.streaming.dstream.ShuffledDStream@3e491569 has not been initialized
有人說jar包重新編譯后需要刪掉checkpoint目錄,但是我沒有重新編譯,我的運行方式是yarn-client方式,請問朋友們知道是什么原因嗎
轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/72699.html
標籤:Spark
上一篇:分布式系統如何部署到阿里云上
