Skip to content

Commit

Permalink
make getThisTaskIndex and getComponentTasks consistent
Browse files Browse the repository at this point in the history
  • Loading branch information
Nathan Marz committed Feb 13, 2012
1 parent 2775dd5 commit 3651b49
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions src/jvm/backtype/storm/task/TopologyContext.java
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,10 @@ public TopologyContext(StormTopology topology, Map<Integer, String> taskToCompon
curr.add(task);
_componentToTasks.put(component, curr);
}
for(String component: _componentToTasks.keySet()) {
List<Integer> tasks = _componentToTasks.get(component);
Collections.sort(tasks);
}
}

/**
Expand Down

0 comments on commit 3651b49

Please sign in to comment.