[ https://issues.apache.org/jira/browse/BEAM-10940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17549060#comment-17549060 ]
Danny McCormick commented on BEAM-10940: ---------------------------------------- This issue has been migrated to https://github.com/apache/beam/issues/20668 > Portable Flink runner should handle DelayedBundleApplication from > ProcessBundleResponse. > ---------------------------------------------------------------------------------------- > > Key: BEAM-10940 > URL: https://issues.apache.org/jira/browse/BEAM-10940 > Project: Beam > Issue Type: New Feature > Components: runner-flink > Reporter: Boyuan Zhang > Priority: P3 > Time Spent: 13.5h > Remaining Estimate: 0h > > 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. -- This message was sent by Atlassian Jira (v8.20.7#820007)