raoraoxiong opened a new pull request, #28964: URL: https://github.com/apache/flink/pull/28964
## Purpose Completes the Regional Checkpoint feature (FLIP-600 Phase 6) by adding Per-Region timeout handling and bounded source forced global checkpoint, plus end-to-end integration tests. ## Changes **Commit 1: Per-Region timeout handling and bounded source forced global checkpoint** - Per-Region Timeout: when a task neither acknowledges nor declines within checkpoint timeout, CheckpointCanceller marks unacknowledged tasks as declined and triggers `tryCompleteRegionalCheckpoint` instead of aborting (FLIP-600 Section 9) - Bounded Source: DefaultExecutionGraph injects `allSourcesFinishedChecker`; when all sources finished, next checkpoint is forced global to ensure side effects (e.g. Kafka transactions) are committed before job termination - Add RegionalCheckpointTimeoutTest and RegionalCheckpointBoundedSourceTest **Commit 2: Integration tests** - Add RegionalCheckpointITCase with white-box detection signals (numRegionalFallbackNotifications, numRegionalCompleteNotifications) - RegionFailingMapFunction implements CheckpointListener to verify notification dispatch - Tests: regional checkpoint during region failover, source data not lost, forced global after consecutive limit, ALL_TO_ALL topology fallback ## Testing - Unit tests: timeout path, bounded source forced global (Tier 2 abort + reset) - Integration tests: end-to-end with MiniCluster ## Dependencies - Depends on PR #2 (FLINK-40209): Regional Checkpoint core mechanism and notification dispatch Generated-by: CodeBuddy Code (GLM-5.2) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
