[FLINK-31119] JobRecoveryITCase.testTaskFailureRecovery failed due to the job not finishing successfully

• Type: Technical Debt
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.17.0
• Fix Version/s: 1.17.0
• Component/s: Runtime / Coordination
• Labels: pull-request-available test-stability
• Assignee: Chesnay Schepler
• Reporter: Matthias Pohl
• Created: 17/Feb/23 10:03
• Updated: 20/Feb/23 14:08
• Resolved: 20/Feb/23 14:08

Description

https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=46247&view=logs&j=0e7be18f-84f2-53f0-a32d-4a5e4a174679&t=7c1d86e3-35bd-5fd5-3b7c-30c126a78702&l=8523

Feb 17 02:24:35 [ERROR] Tests run: 2, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 24.074 s <<< FAILURE! - in org.apache.flink.runtime.jobmaster.JobRecoveryITCase
Feb 17 02:24:35 [ERROR] org.apache.flink.runtime.jobmaster.JobRecoveryITCase.testTaskFailureRecovery  Time elapsed: 20.981 s  <<< FAILURE!
Feb 17 02:24:35 java.lang.AssertionError: 
Feb 17 02:24:35 
Feb 17 02:24:35 Expected: is <true>
Feb 17 02:24:35      but: was <false>
Feb 17 02:24:35 	at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)
Feb 17 02:24:35 	at org.junit.Assert.assertThat(Assert.java:964)
Feb 17 02:24:35 	at org.junit.Assert.assertThat(Assert.java:930)
Feb 17 02:24:35 	at org.apache.flink.runtime.jobmaster.JobRecoveryITCase.runTaskFailureRecoveryTest(JobRecoveryITCase.java:79)
Feb 17 02:24:35 	at org.apache.flink.runtime.jobmaster.JobRecoveryITCase.testTaskFailureRecovery(JobRecoveryITCase.java:63)
Feb 17 02:24:35 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
[...]

The actual cause is that unexpected data was received:

02:24:35,301 [    Receiver (5/5)#1] WARN  org.apache.flink.runtime.taskmanager.Task                    [] - Receiver (5/5)#1 (d88e16a5e3c6f2c08cf3924d93ea18e2_28065fbb1d26fe99e018d3b846860dd3_4_1) switched from RUNNING to FAILED with failure cause:
java.lang.Exception: Wrong data received.
        at org.apache.flink.runtime.jobmaster.TestingAbstractInvokables$Receiver.invoke(TestingAbstractInvokables.java:83) ~[test-classes/:?]
        at org.apache.flink.runtime.jobmaster.JobRecoveryITCase$FailingOnceReceiver.invoke(JobRecoveryITCase.java:126) ~[test-classes/:?]
        at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:952) ~[classes/:?]
        at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:931) [classes/:?]
        at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:745) [classes/:?]
        at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562) [classes/:?]
        at java.lang.Thread.run(Thread.java:748) [?:1.8.0_292]

Issue Links

• is related to: FLINK-30895 SlotSharingSlotAllocator may waste slots
• links to: GitHub Pull Request #21973