Github user Ethanlm commented on a diff in the pull request:
https://github.com/apache/storm/pull/2630#discussion_r180615319
--- Diff:
storm-server/src/main/java/org/apache/storm/scheduler/resource/ResourceAwareScheduler.java
---
@@ -100,49 +180,88 @@ private static void markFailedTopology(User u,
Cluster c, TopologyDetails td, St
u.markTopoUnsuccess(td);
}
+ private void cancelAllPendingClusterStateChanged() {
+ if (!schedulingInBackground.isEmpty()) {
+ LOG.warn("Canceling scheduling of {} cluster state changed",
schedulingInBackground.keySet());
--- End diff --
Is it "Canceling scheduling of {} _**because of**_ cluster state changed"?
---
