Re: Flink job throws ClassNotFoundException on job restart

2016-10-05 Thread static-max
I went back to commit 2afc092461cf68cf0f3c26a3ab4c58a7bd68cf71 on MASTER, seems to work. 2016-10-05 15:48 GMT+02:00 static-max : > Hi Stephan, > > thanks for the quick answer! I try to go to an older revision, > > Best, > Max > > 2016-10-05 12:10 GMT+02:00 Stephan Ewen : > >> Hi! >> >> The master

Re: Flink job throws ClassNotFoundException on job restart

2016-10-05 Thread static-max
Hi Stephan, thanks for the quick answer! I try to go to an older revision, Best, Max 2016-10-05 12:10 GMT+02:00 Stephan Ewen : > Hi! > > The master has a temporary regression due to the Work In Progress for the > "changing parallelism of savepoints" feature. > We'll try and complete the change

Re: Flink job throws ClassNotFoundException on job restart

2016-10-05 Thread Stephan Ewen
Hi! The master has a temporary regression due to the Work In Progress for the "changing parallelism of savepoints" feature. We'll try and complete the change today, then it should work again. Sorry for the inconvenience. Can you work with a revision from last week for today? Stephan On Wed, Oc

Flink job throws ClassNotFoundException on job restart

2016-10-05 Thread none none
I'm running Flink on YARN with two taskmanagers. I wrote a simple job that consumes messages from Kafka. The job runs on taskmanager 1. When I kill taskmanager 1 (via *kill PID*), the job gets restarted on taskmanager 2. So far so good. But right after starting the consumer the execution fails: ja