It turns out to be a bug in application code. Thank you!
From: Haopu Wang
Sent: 2016年11月4日 17:23
To: user@spark.apache.org; Cody Koeninger
Subject: InvalidClassException when load KafkaDirectStream from checkpoint
(Spark 2.0.0)
When I load spark
When I load spark checkpoint, I get below error. Do you have any idea?
Much thanks!
*
2016-11-04 17:12:19,582 INFO
[org.apache.spark.streaming.CheckpointReader] (main;) Checkpoint files
found:
file:/d:/temp/checkpoint/checkpoint-147825070,file:/d:/temp/checkpoi
