From d6ff39b39c4cd4eda319fb1e169528b4c5613c3f Mon Sep 17 00:00:00 2001
From: zcb <2056268568@qq.com>
Date: Sun, 19 Mar 2017 16:31:34 +0800
Subject: [PATCH] makes setting of 'zookeeper.sasl.disable' work correctly

---
 .../main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java b/flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java
index 1b73dc76e13e9..8fe6906aaf56b 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java
@@ -43,6 +43,7 @@
 import org.apache.flink.util.ConfigurationUtil;
 import org.apache.flink.util.Preconditions;
 import org.apache.zookeeper.ZooDefs;
+import org.apache.zookeeper.client.ZooKeeperSaslClient;
 import org.apache.zookeeper.data.ACL;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -89,6 +90,7 @@ public static CuratorFramework startCuratorFramework(Configuration configuration
 
 		boolean disableSaslClient = configuration.getBoolean(ConfigConstants.ZOOKEEPER_SASL_DISABLE,
 				ConfigConstants.DEFAULT_ZOOKEEPER_SASL_DISABLE);
+		System.setProperty(ZooKeeperSaslClient.ENABLE_CLIENT_SASL_KEY, String.valueOf(!disableSaslClient));
 
 		ACLProvider aclProvider;