[ 
https://issues.apache.org/jira/browse/METRON-793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15937177#comment-15937177
 ] 

ASF GitHub Bot commented on METRON-793:
---------------------------------------

Github user justinleet commented on a diff in the pull request:

    https://github.com/apache/incubator-metron/pull/486#discussion_r107438798
  
    --- Diff: 
metron-platform/metron-parsers/src/test/java/org/apache/metron/parsers/integration/components/ParserTopologyComponent.java
 ---
    @@ -97,6 +99,19 @@ public void start() throws UnableToStartException {
       public void stop() {
         if(stormCluster != null) {
           stormCluster.shutdown();
    +      if(new File("logs/workers-artifacts").exists()) {
    +        Path rootPath = Paths.get("logs");
    +        Path destPath = Paths.get("target/logs");
    +        try {
    +          Files.move(rootPath, destPath);
    +          Files.walk(destPath)
    --- End diff --
    
    Same deal with FileUtils.deleteDirectory() here


> 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)

Reply via email to