Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/4900
I see, okay, the status checking in `trigger()` together with the tight
locking contract with StreamTask fixes that.
My feeling is that this is a workaround to support another non-ideal
design, but it should work as a temporary fix, because it is not possible to
rework the file monitoring source before the next release.
Good with me to merge this...---
