Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4787 Actually, going back here. I would like to not merge this after all. The reason being that in my test run, I found that this does not handle concurrent deletes correctly after all: https://travis-ci.org/StephanEwen/incubator-flink/jobs/287502995
---