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