Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2475#discussion_r162313649
--- Diff: storm-client/src/jvm/org/apache/storm/spout/ShellSpout.java ---
@@ -177,6 +179,7 @@ private void handleMetrics(ShellMsg shellMsg) {
private void querySubprocess() {
try {
markWaitingSubprocess();
+ _logHandler.setUpContext(_process, _context);
--- End diff --
This can be on-time setup, and maybe better to move this to `open()`, since
we are more familiar with initializing everything in it.
---
