Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5416#discussion_r175480192 --- 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 is this timeout increase not a little bit arbitrary. Can we implement some better waiting strategy? Like waiting for the respective log statement, for example.
---