RMQSource synchronous message ack

2019-03-05 Thread Gabriel Candal
Hi, Recently I've opened a Stack Overflow question about latency spikes (~500ms) after a checkpoint operation, even though the operation itself was relatively fast (~50ms). I've come to realize that the c

Task Manager high availability

2019-03-04 Thread Gabriel Candal
Hi, Before the actual question, and just to make sure my assumptions are correct, my understanding is that Flink's current behaviour is: - Job Manager failure under an highly available setup: a standby Job Manager takes over, no impact on the job - Task Manager failure, with enough free slots in