Repository: flink Updated Branches: refs/heads/master 97611c245 -> 2eb5cfeb2
[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/2eb5cfeb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2eb5cfeb Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2eb5cfeb Branch: refs/heads/master Commit: 2eb5cfeb2dad061aa8e84040bd648b5198d2d142 Parents: 97611c2 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:57:42 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/2eb5cfeb/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
