Details
-
New Feature
-
Status: Open
-
P3
-
Resolution: Unresolved
-
None
-
None
-
None
Description
SDF can produce residuals by self-checkpoint, which will be returned to runner by ProcessBundleResponse.DelayedBundleApplication. The portable runner should be able to handle the DelayedBundleApplication and reschedule it based on the timestamp.
Attachments
Issue Links
- blocks
-
BEAM-11070 Portable FlinkRunnerTestStreaming.test_register_finalizations is flkay
- Resolved
- links to