Github user d2r commented on a diff in the pull request: https://github.com/apache/storm/pull/2881#discussion_r227936615 --- Diff: storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java --- @@ -155,6 +156,7 @@ public WorkerState(Map<String, Object> conf, IContext mqContext, String topology this.receiver = this.mqContext.bind(topologyId, port); this.topologyId = topologyId; this.assignmentId = assignmentId; + this.numaId = ""; --- End diff -- Do we need this? It is always going to be an empty String.
---