Github user d2r commented on a diff in the pull request:
https://github.com/apache/storm/pull/2603#discussion_r176786400
--- Diff:
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java ---
@@ -1754,7 +1762,7 @@ private TopologyResources
getResourcesForTopology(String topoId, StormBase base)
try {
IStormClusterState state = stormClusterState;
TopologyDetails details = readTopologyDetails(topoId,
base);
- Assignment assignment = state.assignmentInfo(topoId, null);
+ Assignment assignment = getAssignmentInfo(state, topoId);
--- End diff --
We can just use `stormClusterState` directly without making another `state`
variable. (Here and in the next method.)
---