Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5416#discussion_r175677410 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java --- @@ -105,7 +105,7 @@ public void testDetachedMode() throws InterruptedException, IOException { } //additional sleep for the JM/TM to start and establish connection - sleep(2000); + sleep(3000); --- End diff -- Hmm, waiting for the log statement might be problematic, because if the job can not start due to other issues, then there will be no log files and the wait can be forever.
---