[FLINK-32478] SourceCoordinatorAlignmentTest.testAnnounceCombinedWatermarkWithoutStart fails

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.18.0, 1.16.3, 1.17.2
• Fix Version/s: 1.18.0, 1.16.3, 1.17.2
• Component/s: Connectors / Common
• Labels: pull-request-available test-stability
• Assignee: Rui Fan
• Reporter: Rui Fan
• Created: 29/Jun/23 06:14
• Updated: 30/Jun/23 12:16
• Resolved: 30/Jun/23 12:15

Description

SourceCoordinatorAlignmentTest.testAnnounceCombinedWatermarkWithoutStart fails

 

Root cause: multiple sources share the same thread pool, and the second source cannot start due to the first source closes the shared thread pool.

https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=50611&view=logs&j=0da23115-68bb-5dcd-192c-bd4c8adebde1&t=24c3384f-1bcb-57b3-224f-51bf973bbee8&l=8613

Issue Links

• causes: FLINK-32495 SourceCoordinatorAlignmentTest.testWatermarkAlignmentWithTwoGroups fails
• duplicates: FLINK-32487 SourceCoordinatorAlignmentTest.testAnnounceCombinedWatermarkWithoutStart fails with RejectedExecution
• is caused by: FLINK-32411 SourceCoordinator thread leaks when job recovers from checkpoint
• is caused by: FLINK-32316 Duplicated announceCombinedWatermark task maybe scheduled if jobmanager failover
• links to: GitHub Pull Request #22900
• links to: GitHub Pull Request #22910