Modify comments
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/13e8b11a Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/13e8b11a Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/13e8b11a Branch: refs/heads/master Commit: 13e8b11a580cea2e67760d14b6efef9a943b3faf Parents: 58f1161 Author: zhuol <[email protected]> Authored: Fri Mar 25 15:35:54 2016 -0500 Committer: zhuol <[email protected]> Committed: Fri Mar 25 15:35:54 2016 -0500 ---------------------------------------------------------------------- .../storm/scheduler/resource/TestResourceAwareScheduler.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/13e8b11a/storm-core/test/jvm/org/apache/storm/scheduler/resource/TestResourceAwareScheduler.java ---------------------------------------------------------------------- diff --git a/storm-core/test/jvm/org/apache/storm/scheduler/resource/TestResourceAwareScheduler.java b/storm-core/test/jvm/org/apache/storm/scheduler/resource/TestResourceAwareScheduler.java index 9cfdc6e..5ae1432 100644 --- a/storm-core/test/jvm/org/apache/storm/scheduler/resource/TestResourceAwareScheduler.java +++ b/storm-core/test/jvm/org/apache/storm/scheduler/resource/TestResourceAwareScheduler.java @@ -257,9 +257,10 @@ public class TestResourceAwareScheduler { Map<String, Number> resourceMap = new HashMap<>(); resourceMap.put(Config.SUPERVISOR_CPU_CAPACITY, 400.0); resourceMap.put(Config.SUPERVISOR_MEMORY_CAPACITY_MB, 2000.0); + // to test whether two tasks will be assigned to one or two nodes Map<String, SupervisorDetails> supMap = TestUtilsForResourceAwareScheduler.genSupervisors(2, 2, resourceMap); - TopologyBuilder builder1 = new TopologyBuilder(); // a topology with multiple spouts + TopologyBuilder builder1 = new TopologyBuilder(); builder1.setSpout("wordSpout", new TestWordSpout(), 1).setCPULoad(20.0).setMemoryLoad(200.0); builder1.setBolt("wordCountBolt", new TestWordCounter(), 1).shuffleGrouping("wordSpout").setCPULoad(20.0).setMemoryLoad(200.0); StormTopology stormTopology1 = builder1.createTopology();
