running flink job cluster on kubernetes with HA

s it enough? thanks, Aviad -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

hadoopInputFormat and elasticsearch

Hi, I want to write batch job which reads data from *elasticsearch* using *elasticsearch-hadoop* (https://github.com/elastic/elasticsearch-hadoop/) and *hadoopInputFormat* example code (from https://github.com/genged/flink-playground/blob/master/src/main/java/com/mic/flink/FlinkMain.java): ela

Re: RestartStrategies & checkpoints

d the restart strategy has not been configured, the fixed-delay strategy is used with Integer.MAX_VALUE restart attempts." but still it is not written literally thanks Aviad -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: external checkpoints

I have another way to configure externalized checkpoint? thanks Aviad -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

external checkpoints

Hi, I have several jobs which configured for external check-pointing (enableExternalizedCheckpoints) how can I correlate between checkpoint and jobs. for example, if i want to write script which monitor if the job is up or not and if the job is down it will resume the job from the externalized chec

RestartStrategies & checkpoints

Hi, if my job configured with *setRestartStrategy *and with *enableCheckpointing *(&enableExternalizedCheckpoints). it case of failure and job restart, does it restart with the latest checkpoint or is it restarts without any checkpoint.