You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2015/06/09 14:58:01 UTC
flink git commit: [hotfix] Fix YARNSessionFIFOITCase
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 <al...@gmail.com>
Authored: Tue Jun 9 14:56:17 2015 +0200
Committer: Aljoscha Krettek <al...@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