Skip to content

Commit 2fa0350

Browse files
committed
[FLINK-38404][core] Fix JobMasterTest due to data race
1 parent 3478ddf commit 2fa0350

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1714,7 +1714,7 @@ void testJobFailureWhenGracefulTaskExecutorTermination() throws Exception {
17141714
.equals(event.getName()))
17151715
.map(Event::getAttributes)
17161716
.map(x -> x.get("newJobStatus")))
1717-
.containsExactly(
1717+
.containsSubsequence(
17181718
JobStatus.RUNNING.toString(),
17191719
JobStatus.FAILING.toString(),
17201720
JobStatus.FAILED.toString());
@@ -1755,7 +1755,7 @@ void testJobFailureWhenTaskExecutorHeartbeatTimeout() throws Exception {
17551755
.equals(event.getName()))
17561756
.map(Event::getAttributes)
17571757
.map(x -> x.get("newJobStatus")))
1758-
.containsExactly(
1758+
.containsSubsequence(
17591759
JobStatus.RUNNING.toString(),
17601760
JobStatus.FAILING.toString(),
17611761
JobStatus.FAILED.toString());

0 commit comments

Comments
 (0)