You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/05/10 14:21:42 UTC
[3/9] flink git commit: [hotfix] [tests] Harden
YarnSessionFIFOITCase#testDetachedMode
[hotfix] [tests] Harden YarnSessionFIFOITCase#testDetachedMode
Wait for the completion of the submitted job in order to avoid that we kill
the JM while the TM tries to down load blobs from it.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3c86b6b5
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3c86b6b5
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3c86b6b5
Branch: refs/heads/master
Commit: 3c86b6b575c64409a1153c56618d6929bd2d49de
Parents: 90a0a91
Author: Till Rohrmann <tr...@apache.org>
Authored: Thu May 10 00:45:12 2018 +0200
Committer: Till Rohrmann <tr...@apache.org>
Committed: Thu May 10 16:18:31 2018 +0200
----------------------------------------------------------------------
.../java/org/apache/flink/yarn/YARNSessionFIFOITCase.java | 8 ++------
1 file changed, 2 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/3c86b6b5/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
----------------------------------------------------------------------
diff --git a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
index bdaf2c6..eee6867 100644
--- a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
+++ b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
@@ -177,12 +177,8 @@ public class YARNSessionFIFOITCase extends YarnTestBase {
long startTime = System.nanoTime();
while (System.nanoTime() - startTime < TimeUnit.NANOSECONDS.convert(10, TimeUnit.SECONDS) &&
!(verifyStringsInNamedLogFiles(
- new String[]{isNewMode ? "JobManager successfully registered at ResourceManager"
- : "YARN Application Master started"}, "jobmanager.log") &&
- verifyStringsInNamedLogFiles(
- new String[]{isNewMode ? "Successful registration at job manager"
- : "Starting TaskManager actor"}, "taskmanager.log"))) {
- LOG.info("Still waiting for JM/TM to initialize...");
+ new String[]{"switched from state RUNNING to FINISHED"}, "jobmanager.log"))) {
+ LOG.info("Still waiting for cluster to finish job...");
sleep(500);
}