Just to be clear, did you rebuild your job against spark 1.4.1 as well as
upgrading the cluster?
On Mon, Aug 3, 2015 at 8:36 AM, Netwaver wanglong_...@163.com wrote:
Hi All,
I have a spark streaming + kafka program written by Scala, it
works well on Spark 1.3.1, but after I migrate
Hi All,
I have a spark streaming + kafka program written by Scala, it works
well on Spark 1.3.1, but after I migrate my Spark cluster to 1.4.1 and rerun
this program, I meet below exception:
ERROR scheduler.ReceiverTracker: Deregistered receiver for stream
0: Error starting
