From 3ca135017332861762b56f21401c01e07a545b87 Mon Sep 17 00:00:00 2001
From: "jianran.tfh" <jianran.tfh@taobao.com>
Date: Mon, 12 Mar 2018 11:25:39 +0800
Subject: [PATCH] [FLINK-8917]FlinkMiniCluster default
 createHighAvailabilityServices is not same as ClusterClient

---
 .../apache/flink/runtime/minicluster/FlinkMiniCluster.scala | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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 6c9ee5ba6d6ae..bba69bd8d63ae 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
@@ -128,9 +128,9 @@ abstract class FlinkMiniCluster(
   def this(configuration: Configuration, useSingleActorSystem: Boolean) {
     this(
       configuration,
-      HighAvailabilityServicesUtils.createAvailableOrEmbeddedServices(
-        configuration,
-        ExecutionContext.global),
+      HighAvailabilityServicesUtils.createHighAvailabilityServices(configuration,
+        org.apache.flink.runtime.concurrent.Executors.directExecutor,
+        HighAvailabilityServicesUtils.AddressResolution.TRY_ADDRESS_RESOLUTION),
       useSingleActorSystem)
   }