未验证 提交 d414fe10 编写于 作者: P Piotr Nowojski 提交者: Till Rohrmann

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

This closes #4247.
上级 084bb4f8
......@@ -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);
......
......@@ -310,7 +310,7 @@ abstract class FlinkMiniCluster(
"The FlinkMiniCluster has not been started yet.")
}
} else {
JobClient.startJobClientActorSystem(originalConfiguration)
JobClient.startJobClientActorSystem(originalConfiguration, hostname)
}
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册