You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by zh...@apache.org on 2016/03/28 21:07:25 UTC
[5/8] storm git commit: Modify comments
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 <zh...@yahoo-inc.com>
Authored: Fri Mar 25 15:35:54 2016 -0500
Committer: zhuol <zh...@yahoo-inc.com>
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();