Github user kishorvpatil closed the pull request at:
https://github.com/apache/storm/pull/2603
---
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)
Github user d2r commented on a diff in the pull request:
https://github.com/apache/storm/pull/2603#discussion_r176771823
--- Diff:
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java ---
@@ -1196,6 +1198,12 @@ private IStormClusterState getStormClusterState() {
Github user d2r commented on a diff in the pull request:
https://github.com/apache/storm/pull/2603#discussion_r176777374
--- Diff:
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java ---
@@ -1944,6 +1957,7 @@ private void mkAssignments(String scratchTopoId)
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
GitHub user kishorvpatil opened a pull request:
https://github.com/apache/storm/pull/2603
[STORM-3003] Adding Assignment caching to Nimbus
Since nimbus ( scheduler generates assignments) it can cache it instead of
polling for it from ZK or other state manager. This would improve
