RE: Checkpointing in Flink 1.5.0

2018-07-03 Thread Jash, Shaswata (Nokia - IN/Bangalore)
Hello Chesnay, Cluster (in kubernetes)-wide checkpointing directory using glusterfs volume mount (thus file access protocol file:///) was working fine till 1.4.2 for us. So we like to understand where the breakage happened in 1.5.0. Can you please mention me the relevant source code files relate

Question regarding effect of 'restart-strategy: none' on Flink (1.4.1) JobManager HA

2018-03-14 Thread Jash, Shaswata (Nokia - IN/Bangalore)
Hello Flink-Experts, I am observing that even after setting 'restart-strategy: none' with Flink JobManager HA (High Availability) setup, JobManager is still continuing restarting the ongoing jobs after failover. Is it the expected behavior? Jobs have not used any checkpoint/savepoints. My under

Re: Question regarding effect of 'restart-strategy: none' on Flink (1.4.1) JobManager HA

2018-03-14 Thread Jash, Shaswata (Nokia - IN/Bangalore)
igh-availability Am 14.03.18 um 13:20 schrieb Jash, Shaswata (Nokia - IN/Bangalore): Hello Flink-Experts, I am observing that even after setting ‘restart-strategy: none’ with Flink JobManager HA (High Availability) setup, JobManager is still continuing restarting the ongoing jobs after fai