Modify comment
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/91f8a456 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/91f8a456 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/91f8a456 Branch: refs/heads/master Commit: 91f8a456d99f92aabb50898f6935a7b44015bf40 Parents: 13e8b11 Author: zhuol <[email protected]> Authored: Fri Mar 25 15:37:41 2016 -0500 Committer: zhuol <[email protected]> Committed: Fri Mar 25 15:37:41 2016 -0500 ---------------------------------------------------------------------- .../storm/scheduler/resource/TestResourceAwareScheduler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/91f8a456/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 5ae1432..720f2d6 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 @@ -308,7 +308,7 @@ public class TestResourceAwareScheduler { resourceMap.put(Config.SUPERVISOR_MEMORY_CAPACITY_MB, 2000.0); 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(), 2).setCPULoad(250.0).setMemoryLoad(1000.0, 200.0); builder1.setBolt("wordCountBolt", new TestWordCounter(), 1).shuffleGrouping("wordSpout").setCPULoad(100.0).setMemoryLoad(500.0, 100.0); StormTopology stormTopology1 = builder1.createTopology();
