You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@metron.apache.org by ce...@apache.org on 2017/03/30 22:17:26 UTC
[2/3] incubator-metron git commit: METRON-797: Pass security.protocol
and enable auto-renew for the storm topologies
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 <ju...@gmail.com>
Authored: Wed Mar 29 09:16:34 2017 -0400
Committer: cstella <ce...@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();