Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2358#discussion_r143374510
--- Diff:
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java ---
@@ -1825,6 +1844,11 @@ private void mkAssignments(String scratchTopoId)
throws Exception {
if (!newAssignments.equals(existingAssignments)) {
LOG.debug("RESETTING id->resources and
id->worker-resources cache!");
+ LOG.info("Fragmentation after scheduling is: {} MB, {}
PCore CPUs", fragmentedMemory(), fragmentedCpu());
+ //map.forEach((x, y) -> System.out.println(x + ": " + y));
--- End diff --
Let's remove the comment.
---
