metron-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ceste...@apache.org
Subject [2/3] incubator-metron git commit: METRON-797: Pass security.protocol and enable auto-renew for the storm topologies
Date Thu, 30 Mar 2017 22:17:26 GMT
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 <justinjleet@gmail.com>
Authored: Wed Mar 29 09:16:34 2017 -0400
Committer: cstella <cestella@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();


Mime
View raw message