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

    https://github.com/apache/storm/pull/2475#discussion_r162313151
  
    --- Diff: storm-client/src/jvm/org/apache/storm/task/ShellBolt.java ---
    @@ -145,6 +148,8 @@ public void prepare(Map<String, Object> topoConf, 
TopologyContext context,
                 workerTimeoutMills = 1000 * 
ObjectReader.getInt(topoConf.get(Config.SUPERVISOR_WORKER_TIMEOUT_SECS));
             }
     
    +        _logHandler = ShellUtils.getLogHandler(topoConf);
    --- End diff --
    
    This should be also placed to spout as I commented above.


---

Reply via email to