You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mx...@apache.org on 2016/11/04 19:09:10 UTC
[2/2] flink git commit: [FLINK-3813][yarn] wait for CLI to complete
before checking output
[FLINK-3813][yarn] wait for CLI to complete before checking output
This closes #2749.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e4807621
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e4807621
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e4807621
Branch: refs/heads/master
Commit: e4807621b8f41fc4f9fa69f423f1fbf7bba05218
Parents: 1c0c668
Author: Maximilian Michels <mx...@apache.org>
Authored: Wed Oct 26 16:37:56 2016 +0100
Committer: Maximilian Michels <mx...@apache.org>
Committed: Fri Nov 4 20:07:42 2016 +0100
----------------------------------------------------------------------
.../java/org/apache/flink/yarn/YARNSessionFIFOITCase.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/e4807621/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 c5659eb..68cc73d 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
@@ -81,10 +81,11 @@ public class YARNSessionFIFOITCase extends YarnTestBase {
* Test regular operation, including command line parameter parsing.
*/
@Test(timeout=60000) // timeout after a minute.
- public void testDetachedMode() {
+ public void testDetachedMode() throws InterruptedException {
LOG.info("Starting testDetachedMode()");
addTestAppender(FlinkYarnSessionCli.class, Level.INFO);
- startWithArgs(new String[]{"-j", flinkUberjar.getAbsolutePath(),
+ Runner runner =
+ startWithArgs(new String[]{"-j", flinkUberjar.getAbsolutePath(),
"-t", flinkLibFolder.getAbsolutePath(),
"-n", "1",
"-jm", "768",
@@ -93,6 +94,8 @@ public class YARNSessionFIFOITCase extends YarnTestBase {
"--detached"},
"Flink JobManager is now running on", RunTypes.YARN_SESSION);
+ // before checking any strings outputted by the CLI, first give it time to return
+ runner.join();
checkForLogString("The Flink YARN client has been started in detached mode");
LOG.info("Waiting until two containers are running");