Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2754
Thanks for the thorough review!
Addressed the feedback, rebased, and will merge as soon as Travis gives a
green light...
---
If your project is set up for it, you can reply to this
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2754
Btw: Going through the `BarrierBuffer` and the way events are handled was
really instructive :-)
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2754
Really good changes @StephanEwen. With the safeguard against spilling too
much data while aligning the checkpoint barriers Flink will be more robust and
deliver a better user experience in
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2754
If no one has any objection to this, I would merge it by tomorrow...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your