Hello, everyone. Flink CI test results are currently unstable, with more than 10 flaky tests. We need developers' help to resolve them. I’ve assigned some, but many failures need community support. Below is the detailed list: • https://issues.apache.org/jira/browse/FLINK-38404: JobMasterTest consistently fails. • https://issues.apache.org/jira/browse/FLINK-38402: EventTimeWindowCheckpointingITCase fails frequently. • https://issues.apache.org/jira/browse/FLINK-38439: SqlGatewayServiceITCase fails for the first time. • https://issues.apache.org/jira/browse/FLINK-38441: ExecutionGraphCoLocationRestartTest is not frequently reproducible. • https://issues.apache.org/jira/browse/FLINK-38408: MapStateNullValueCheckpointingITCase is not frequently reproducible. • https://issues.apache.org/jira/browse/FLINK-38407: GroupAggregateRestoreTest is not frequently reproducible. • https://issues.apache.org/jira/browse/FLINK-38406: DefaultSchedulerCheckpointCoordinatorTest is not frequently reproducible. • https://issues.apache.org/jira/browse/FLINK-38405: ChangelogNormalizeRestoreTest is not frequently reproducible. • https://issues.apache.org/jira/browse/FLINK-38403: UnalignedCheckpointITCase is not frequently reproducible. • https://issues.apache.org/jira/browse/FLINK-38369: RestClientTest is not frequently reproducible. • https://issues.apache.org/jira/browse/FLINK-38360: HadoopRecoverableWriterTest is not frequently reproducible. Thanks all ~ 😃

AbstractAsyncRunnableStreamOperatorTest.testCheckpointDrain fails intermittently (log) and it seems irrelevant to the code change (PR).

Error: 04:55:00 04:55:00.123 [ERROR] Tests run: 12, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 6.677 s <<< FAILURE! -- in org.apache.flink.runtime.asyncprocessing.operators.AbstractAsyncRunnableStreamOperatorTest
Error: 04:55:00 04:55:00.123 [ERROR] org.apache.flink.runtime.asyncprocessing.operators.AbstractAsyncRunnableStreamOperatorTest.testCheckpointDrain -- Time elapsed: 0.021 s <<< FAILURE!
Oct 11 04:55:00 org.opentest4j.AssertionFailedError: 
Oct 11 04:55:00 
Oct 11 04:55:00 expected: 1
Oct 11 04:55:00  but was: 0
Oct 11 04:55:00 	at org.apache.flink.runtime.asyncprocessing.operators.AbstractAsyncRunnableStreamOperatorTest.testCheckpointDrain(AbstractAsyncRunnableStreamOperatorTest.java:254)
Oct 11 04:55:00 	at java.base/java.lang.reflect.Method.invoke(Method.java:568)
Oct 11 04:55:00 	at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:373)
Oct 11 04:55:00 	at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1182)
Oct 11 04:55:00 	at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1655)
Oct 11 04:55:00 	at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1622)
Oct 11 04:55:00 	at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:165)

@Hang Ruan happy to help tackle, if you want to assign any to me, I'm

ctrlaltdilj

@Diljeet Singh Thanks for your help. If you are interested in any, be free to comment at the jira.