flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trohrm...@apache.org
Subject flink git commit: [FLINK-7066] [tests] Fix integration tests in airplane mode
Date Mon, 03 Jul 2017 12:29:06 GMT
Repository: flink
Updated Branches:
  refs/heads/master 084bb4f8e -> d414fe101


[FLINK-7066] [tests] Fix integration tests in airplane mode

This closes #4247.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d414fe10
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d414fe10
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d414fe10

Branch: refs/heads/master
Commit: d414fe10163895cbf235dacef36d9806c8a675d4
Parents: 084bb4f
Author: Piotr Nowojski <piotr.nowojski@gmail.com>
Authored: Mon Jul 3 13:55:27 2017 +0200
Committer: Till Rohrmann <trohrmann@apache.org>
Committed: Mon Jul 3 14:13:20 2017 +0200

----------------------------------------------------------------------
 .../src/main/java/org/apache/flink/runtime/client/JobClient.java | 4 ++--
 .../org/apache/flink/runtime/minicluster/FlinkMiniCluster.scala  | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/d414fe10/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClient.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClient.java b/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClient.java
index 86d927a..6a49564 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClient.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClient.java
@@ -68,11 +68,11 @@ public class JobClient {
 
 	private static final Logger LOG = LoggerFactory.getLogger(JobClient.class);
 
-	public static ActorSystem startJobClientActorSystem(Configuration config)
+	public static ActorSystem startJobClientActorSystem(Configuration config, String hostname)
 			throws IOException {
 		LOG.info("Starting JobClient actor system");
 
-		Option<Tuple2<String, Object>> remoting = new Some<>(new Tuple2<String,
Object>("", 0));
+		Option<Tuple2<String, Object>> remoting = new Some<>(new Tuple2<String,
Object>(hostname, 0));
 
 		// start a remote actor system to listen on an arbitrary port
 		ActorSystem system = AkkaUtils.createActorSystem(config, remoting);

http://git-wip-us.apache.org/repos/asf/flink/blob/d414fe10/flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/FlinkMiniCluster.scala
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/FlinkMiniCluster.scala
b/flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/FlinkMiniCluster.scala
index a829059..0e6f102 100644
--- a/flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/FlinkMiniCluster.scala
+++ b/flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/FlinkMiniCluster.scala
@@ -310,7 +310,7 @@ abstract class FlinkMiniCluster(
           "The FlinkMiniCluster has not been started yet.")
       }
     } else {
-      JobClient.startJobClientActorSystem(originalConfiguration)
+      JobClient.startJobClientActorSystem(originalConfiguration, hostname)
     }
   }
 


Mime
View raw message