LocalFileSystemCodeDistributor shoudl work with secure ZK.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/e5a96f43 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/e5a96f43 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/e5a96f43 Branch: refs/heads/nimbus-ha-branch Commit: e5a96f43839a7f5bc6eedb212c1b30c004af914e Parents: 256c35a Author: Parth Brahmbhatt <[email protected]> Authored: Thu Dec 18 11:28:54 2014 -0800 Committer: Parth Brahmbhatt <[email protected]> Committed: Thu Dec 18 11:28:54 2014 -0800 ---------------------------------------------------------------------- .../storm/nimbus/LocalFileSystemCodeDistributor.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/e5a96f43/storm-core/src/jvm/backtype/storm/nimbus/LocalFileSystemCodeDistributor.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/nimbus/LocalFileSystemCodeDistributor.java b/storm-core/src/jvm/backtype/storm/nimbus/LocalFileSystemCodeDistributor.java index a379983..bcf0167 100644 --- a/storm-core/src/jvm/backtype/storm/nimbus/LocalFileSystemCodeDistributor.java +++ b/storm-core/src/jvm/backtype/storm/nimbus/LocalFileSystemCodeDistributor.java @@ -1,5 +1,7 @@ package backtype.storm.nimbus; +import backtype.storm.Config; +import backtype.storm.utils.ZookeeperAuthInfo; import com.google.common.collect.Lists; import org.apache.commons.io.FileUtils; import org.apache.curator.framework.CuratorFramework; @@ -16,9 +18,7 @@ import static backtype.storm.Config.*; import static backtype.storm.utils.Utils.downloadFromHost; import static backtype.storm.utils.Utils.newCurator; -/** - * Created by pbrahmbhatt on 12/12/14. - */ + public class LocalFileSystemCodeDistributor implements ICodeDistributor { private static final Logger LOG = LoggerFactory.getLogger(LocalFileSystemCodeDistributor.class); private CuratorFramework zkClient; @@ -29,9 +29,9 @@ public class LocalFileSystemCodeDistributor implements ICodeDistributor { this.conf = conf; List<String> zkServers = (List<String>) conf.get(STORM_ZOOKEEPER_SERVERS); int port = (Integer) conf.get(STORM_ZOOKEEPER_PORT); - zkClient = newCurator(conf, zkServers, port, (String) conf.get(STORM_ZOOKEEPER_ROOT)); + ZookeeperAuthInfo zkAuthInfo = new ZookeeperAuthInfo(conf); + zkClient = newCurator(conf, zkServers, port, (String) conf.get(STORM_ZOOKEEPER_ROOT), zkAuthInfo); zkClient.start(); - //TODO secure zk. } @Override
