METRON-797: Pass security.protocol and enable auto-renew for the storm topologies
Project: http://git-wip-us.apache.org/repos/asf/incubator-metron/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-metron/commit/e03636d8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-metron/tree/e03636d8 Diff: http://git-wip-us.apache.org/repos/asf/incubator-metron/diff/e03636d8 Branch: refs/heads/master Commit: e03636d8d3fa18bbd3ed53cd55e66b81eb84603d Parents: dae102b Author: justinleet <justinjl...@gmail.com> Authored: Wed Mar 29 09:16:34 2017 -0400 Committer: cstella <ceste...@gmail.com> Committed: Wed Mar 29 09:16:34 2017 -0400 ---------------------------------------------------------------------- .../apache/metron/parsers/topology/ParserTopologyCLI.java | 9 --------- 1 file changed, 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/e03636d8/metron-platform/metron-parsers/src/main/java/org/apache/metron/parsers/topology/ParserTopologyCLI.java ---------------------------------------------------------------------- diff --git a/metron-platform/metron-parsers/src/main/java/org/apache/metron/parsers/topology/ParserTopologyCLI.java b/metron-platform/metron-parsers/src/main/java/org/apache/metron/parsers/topology/ParserTopologyCLI.java index d83146f..7523333 100644 --- a/metron-platform/metron-parsers/src/main/java/org/apache/metron/parsers/topology/ParserTopologyCLI.java +++ b/metron-platform/metron-parsers/src/main/java/org/apache/metron/parsers/topology/ParserTopologyCLI.java @@ -17,7 +17,6 @@ */ package org.apache.metron.parsers.topology; -import com.google.common.collect.ImmutableList; import org.apache.metron.storm.kafka.flux.SpoutConfiguration; import org.apache.storm.Config; import org.apache.storm.LocalCluster; @@ -312,14 +311,6 @@ public class ParserTopologyCLI { securityProtocol ); Config stormConf = ParserOptions.getConfig(cmd); - if(securityProtocol.isPresent() && !stormConf.containsKey(Config.TOPOLOGY_AUTO_CREDENTIALS)) { - //if I'm specifying it already, then I won't impose autohdfs and autohbase - List<String> autoCredentials = new ArrayList<>(); - for (String credential : ImmutableList.of(AutoHDFS.class.getName(), AutoHBase.class.getName())) { - autoCredentials.add(credential); - } - stormConf.put( Config.TOPOLOGY_AUTO_CREDENTIALS , autoCredentials ); - } if (ParserOptions.TEST.has(cmd)) { stormConf.put(Config.TOPOLOGY_DEBUG, true); LocalCluster cluster = new LocalCluster();
