Hey Matthias,
Thanks for reporting the Exception thrown, we were not preparing for this
use case yet. We fixed it with Gyula, he is pushing a fix for it right now:
When the job is cancelled (for example due to shutting down the executor
underneath) you should not see that InterruptedException as
As a followup - I think it would be a good thing to add a way to gracefully
stop a streaming job.
Something that sends close to the sources, and they quit.
We can use this for graceful shutdown wen re-partitioninig / scaling in or
out, ...
On Wed, Apr 1, 2015 at 1:29 PM, Matthias J. Sax
Hi Robert,
thanks for your answer.
I get an InterruptedException when I call shutdown():
java.lang.InterruptedException
at java.lang.Object.wait(Native Method)
at java.lang.Thread.join(Thread.java:1225)
at java.lang.Thread.join(Thread.java:1278)
at
