Skip to content

Commit 583d9ce

Browse files
committed
[FLINK-38404][core] Fix JobMasterTest due to data race
1 parent bc84294 commit 583d9ce

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
@@ -1706,7 +1706,7 @@ void testJobFailureWhenGracefulTaskExecutorTermination() throws Exception {
17061706
.equals(event.getName()))
17071707
.map(Event::getAttributes)
17081708
.map(x -> x.get("newJobStatus")))
1709-
.containsExactly(
1709+
.containsSubsequence(
17101710
JobStatus.RUNNING.toString(),
17111711
JobStatus.FAILING.toString(),
17121712
JobStatus.FAILED.toString());
@@ -1747,7 +1747,7 @@ void testJobFailureWhenTaskExecutorHeartbeatTimeout() throws Exception {
17471747
.equals(event.getName()))
17481748
.map(Event::getAttributes)
17491749
.map(x -> x.get("newJobStatus")))
1750-
.containsExactly(
1750+
.containsSubsequence(
17511751
JobStatus.RUNNING.toString(),
17521752
JobStatus.FAILING.toString(),
17531753
JobStatus.FAILED.toString());

0 commit comments

Comments
 (0)