davidradl commented on code in PR #27091:
URL: https://github.com/apache/flink/pull/27091#discussion_r2416133799


##########
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterTest.java:
##########
@@ -1714,7 +1714,7 @@ void testJobFailureWhenGracefulTaskExecutorTermination() 
throws Exception {
                                                         
.equals(event.getName()))
                                 .map(Event::getAttributes)
                                 .map(x -> x.get("newJobStatus")))
-                .containsExactly(
+                .containsSubsequence(

Review Comment:
   I had a quick look at this is. My concern is that the CREATED event might 
not be coming out - and this is a Flink bug. I would feel for confident if the 
test checks that the CREATED event is coming out and the code be arranged so 
that the race condition does not occur. WDYT?



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to