1: Exception in thread "main" org.apache.spark.SparkException: org.apache.spark.streaming.dstream.MappedDStream@5a69b104 has not been initialized

原因: StreamingContext.checkpoint(...)指定的checkpoint目录下有另一个application生成的checkpoint文件, 导致StreamContext.getOrCreate时加载checkpoint失败, StreamingContext初始化失败
解决方案: 删除该checkpoint目录或换一个目录进行checkpoint。 对于重新编译的Application, checkpoint目录下必须没有其他application生成的checkpoint文件


 

相关文章:

  • 2021-04-16
  • 2022-12-23
  • 2021-08-27
  • 2022-02-24
  • 2021-05-17
  • 2022-12-23
  • 2021-11-29
  • 2021-09-09
猜你喜欢
  • 2021-11-16
  • 2021-12-22
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2021-04-29
相关资源
相似解决方案