[
https://issues.apache.org/jira/browse/METRON-793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15936409#comment-15936409
]
ASF GitHub Bot commented on METRON-793:
---------------------------------------
Github user cestella commented on a diff in the pull request:
https://github.com/apache/incubator-metron/pull/486#discussion_r107428876
--- Diff:
metron-platform/metron-integration-test/src/main/java/org/apache/metron/integration/components/FluxTopologyComponent.java
---
@@ -133,7 +138,25 @@ public void start() throws UnableToStartException {
@Override
public void stop() {
if (stormCluster != null) {
- stormCluster.shutdown();
+ try {
--- End diff --
Note here, we moved to storm 1.0.3 in order to have a single API that would
work between storm 1.0.1 in the HDP profile as well as the default profile.
Storm 1.0.3 writes out worker artifact logs and they need to be cleaned up.
> Migrate to storm-kafka-client kafka spout from storm-kafka
> ----------------------------------------------------------
>
> Key: METRON-793
> URL: https://issues.apache.org/jira/browse/METRON-793
> Project: Metron
> Issue Type: Improvement
> Reporter: Casey Stella
>
> In order to eventually support kerberos, the suggested path is to migrate to
> the new kafka spout (org.apache.storm:storm-kafka-client) which uses the new
> consumer API.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
