Re: Flink Streaming Job Task is getting cancelled silently and causing job to restart

Hi , Yes issue with Bucketing Sink . I removed and replaced Sink with Kafka Sink it worked fine . What could be causing TimerException{java.nio.channels.ClosedByInterruptException} at

Re: Getting RemoteTransportException, HA mode

Thanks! regarding the HA. So the Job will auto recover after a crash understood. Is that true also when deploying new version? easy as simply canceling one job, updating the version and once it is up & running do the same to the other one ? is there anything that is should be highlighted when