The Exception in the thread "main" org. Apache. Spark. SparkException: org. Apache. Spark. Streaming. The dstream. ShuffledDStream @ 3 e491569 from then the initialized
After some people say that jars to recompile need to delete the checkpoint directory, but I don't have to recompile my mode of operation is yarn - client, friends know what reason be excuse me