[FLINK-34994] JobIDLoggingITCase fails because of "checkpoint confirmation for unknown task"

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.20.0
• Fix Version/s: 1.20.0
• Component/s: Tests
• Labels: pull-request-available test-stability
• Assignee: Roman Khachatryan
• Reporter: Roman Khachatryan
• Created: 03/Apr/24 08:13
• Updated: 04/Apr/24 06:10
• Resolved: 04/Apr/24 00:08

Description

https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=58640&view=logs&j=39d5b1d5-3b41-54dc-6458-1e2ddd1cdcf3&t=0c010d0c-3dec-5bf1-d408-7b18988b1b2b&l=8735

Mar 30 03:46:07 03:46:07.807 [ERROR] Tests run: 1, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 7.147 s <<< FAILURE! -- in org.apache.flink.test.misc.JobIDLoggingITCase
Mar 30 03:46:07 03:46:07.807 [ERROR] org.apache.flink.test.misc.JobIDLoggingITCase.testJobIDLogging(ClusterClient) -- Time elapsed: 2.301 s <<< FAILURE!
Mar 30 03:46:07 java.lang.AssertionError: 
Mar 30 03:46:07 [too many events without Job ID logged by org.apache.flink.runtime.taskexecutor.TaskExecutor] 
Mar 30 03:46:07 Expecting empty but was: [Logger=org.apache.flink.runtime.taskexecutor.TaskExecutor Level=DEBUG Message=TaskManager received a checkpoint confirmation for unknown task b45d406844d494592784a88e47d201e2_cbc357ccb763df2852fee8c4fc7d55f2_0_0.]
Mar 30 03:46:07 	at org.apache.flink.test.misc.JobIDLoggingITCase.assertJobIDPresent(JobIDLoggingITCase.java:264)
Mar 30 03:46:07 	at org.apache.flink.test.misc.JobIDLoggingITCase.testJobIDLogging(JobIDLoggingITCase.java:149)
Mar 30 03:46:07 	at java.lang.reflect.Method.invoke(Method.java:498)
Mar 30 03:46:07 	at java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:189)
Mar 30 03:46:07 	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
Mar 30 03:46:07 	at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
Mar 30 03:46:07 	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
Mar 30 03:46:07 	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) 

https://github.com/apache/flink/actions/runs/8502821551/job/23287730632#step:10:8131

https://github.com/apache/flink/actions/runs/8507870399/job/23300810619#step:10:8086

 

 

Issue Links

• relates to: FLINK-34643 JobIDLoggingITCase failed
• links to: GitHub Pull Request #24611