Details
-
Improvement
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
By using the SPLIT_DISTRIBUTE OperatorState in flink to snapshot source checkpoints we make UnboundedSourceWrapper operators rescalable.
Attachments
Issue Links
- depends upon
-
BEAM-1393 Update Flink Runner to Flink 1.2.0
- Resolved
- links to