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
org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService$TriggerTask.run(SystemProcessingTi
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 work
