This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch test in repository https://gitbox.apache.org/repos/asf/flink.git
commit d6ac56ef5abff2941ac0f1a305c26e6c8ec9458a Author: zentol <[email protected]> AuthorDate: Wed Mar 20 16:47:07 2019 +0100 Migrate ActorSystem#shutdown() --- .../mesos/runtime/clusterframework/services/AbstractMesosServices.java | 2 +- .../test/java/org/apache/flink/test/runtime/IPv6HostnamesITCase.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/AbstractMesosServices.java b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/AbstractMesosServices.java index 63f371d..7ae3d51 100644 --- a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/AbstractMesosServices.java +++ b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/AbstractMesosServices.java @@ -55,7 +55,7 @@ public abstract class AbstractMesosServices implements MesosServices { Throwable exception = null; try { - actorSystem.shutdown(); + actorSystem.terminate(); } catch (Throwable t) { exception = ExceptionUtils.firstOrSuppressed(t, exception); } diff --git a/flink-tests/src/test/java/org/apache/flink/test/runtime/IPv6HostnamesITCase.java b/flink-tests/src/test/java/org/apache/flink/test/runtime/IPv6HostnamesITCase.java index 5f40115..bc11dda 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/runtime/IPv6HostnamesITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/runtime/IPv6HostnamesITCase.java @@ -145,7 +145,7 @@ public class IPv6HostnamesITCase extends TestLogger { ActorSystem as = AkkaUtils.createActorSystem( new Configuration(), new Some<scala.Tuple2<String, Object>>(new scala.Tuple2<String, Object>(addr.getHostAddress(), port))); - as.shutdown(); + as.terminate(); log.info("Using address " + addr); return (Inet6Address) addr;
