[GitHub] storm pull request #2603: [STORM-3003] Adding Assignment caching to Nimbus

[d2r]

Github user d2r commented on a diff in the pull request:

    https://github.com/apache/storm/pull/2603#discussion_r177179410
  
    --- Diff: 
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java ---
    @@ -1944,6 +1957,7 @@ private void mkAssignments(String scratchTopoId) 
throws Exception {
                     } else {
                         LOG.info("Setting new assignment for topology id {}: 
{}", topoId, assignment);
                         state.setAssignment(topoId, assignment);
    +                    assignmentsCache.get().put(topoId, assignment);
    --- End diff --
    
    This was addressed.


---