Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2433#discussion_r177712003
--- Diff:
storm-client/src/jvm/org/apache/storm/grouping/LoadAwareShuffleGrouping.java ---
@@ -299,6 +299,8 @@ private Scope calculateScope(Map<Integer, NodeInfo>
taskToNodePort, Map<String,
//taskToNodePort will be an empty map which is refreshed by
WorkerState
if (taskToNodePort.containsKey(task)) {
hosts.add(taskToNodePort.get(task).get_node());
+ } else {
+ LOG.error("Could not find task NodeInfo from local
cache.");
--- End diff --
nit: better to show which task is missing: just adding task id.
---
