Details
-
Bug
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
A parallel instance of UnboundedSourcewrapper may not receive local readers, in which it exits immediately. This prevents checkpointing due to FLINK-2491.