qiuyanjun888 opened a new pull request, #29183: URL: https://github.com/apache/flink/pull/29183
## What is the purpose of the change `ExecutionVertexTest.testResetForNewExecutionReleasesPartitions` can fail intermittently because it asserts that the partition-release future is incomplete immediately after `execution.markFinished()`. Partition release may already be triggered asynchronously at that point. ## Brief change log - Remove the race-prone intermediate completion assertion. - Retain the final assertion that verifies the expected `ResultPartitionID` is released after `resetForNewExecution()`. ## Verifying this change This change is covered by the existing test: - `ExecutionVertexTest#testResetForNewExecutionReleasesPartitions` - Passed in 10 consecutive local runs on the latest `master`. ## Does this pull request potentially affect one of the following parts: - Dependencies: no - Public API: no - Serializers: no - Runtime per-record code paths: no - Deployment or recovery: no - S3 file system connector: no ## Documentation - Does this pull request introduce a new feature? no --- ##### Was generative AI tooling used to co-author this PR? - [X] Yes Generated-by: Codex (GPT-6) -- 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]
