Repository: flink Updated Branches: refs/heads/release-0.9 80cf2c544 -> 348ac8640
[hotfix] Fix YARNSessionFIFOITCase When comparing the hostname, it was comparing capitalised vs. all-lowercase hostname from the yarn config. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/348ac864 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/348ac864 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/348ac864 Branch: refs/heads/release-0.9 Commit: 348ac86406021793d257aeb6f6576d36318acca2 Parents: 80cf2c5 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Tue Jun 9 14:56:17 2015 +0200 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Tue Jun 9 14:58:30 2015 +0200 ---------------------------------------------------------------------- .../main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/348ac864/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java ---------------------------------------------------------------------- diff --git a/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java b/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java index f4febed..ccde5d8 100644 --- a/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java +++ b/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java @@ -71,7 +71,7 @@ import static org.apache.flink.yarn.UtilsTest.checkForLogString; /** - * This test starts a MiniYARNCluster with a FIFO scheudler. + * This test starts a MiniYARNCluster with a FIFO scheduler. * There are no queues for that scheduler. */ public class YARNSessionFIFOITCase extends YarnTestBase { @@ -206,12 +206,12 @@ public class YARNSessionFIFOITCase extends YarnTestBase { String hostname = null; String port = null; while(matches.find()) { - hostname = matches.group(1); + hostname = matches.group(1).toLowerCase(); port = matches.group(2); } LOG.info("Extracted hostname:port: {} {}", hostname, port); - Assert.assertEquals("unable to find hostname in " + parsed, hostname, parsed.getString(ConfigConstants.JOB_MANAGER_IPC_ADDRESS_KEY)); + Assert.assertEquals("unable to find hostname in " + parsed, hostname, parsed.getString(ConfigConstants.JOB_MANAGER_IPC_ADDRESS_KEY).toLowerCase()); Assert.assertEquals("unable to find port in " + parsed, port, parsed.getString(ConfigConstants.JOB_MANAGER_IPC_PORT_KEY)); // test logfile access
