Repository: incubator-eagle Updated Branches: refs/heads/master 6dbdb4f72 -> 668aea0cb
Minor: set task number of UnitTopologyRunner Author: Zhao, Qingwen <qingwz...@apache.org> Closes #527 from qingwen220/quickFix. Project: http://git-wip-us.apache.org/repos/asf/incubator-eagle/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-eagle/commit/668aea0c Tree: http://git-wip-us.apache.org/repos/asf/incubator-eagle/tree/668aea0c Diff: http://git-wip-us.apache.org/repos/asf/incubator-eagle/diff/668aea0c Branch: refs/heads/master Commit: 668aea0cb6f8cea6d102faa95b2f5af9cbea791f Parents: 6dbdb4f Author: Zhao, Qingwen <qingwz...@apache.org> Authored: Wed Oct 19 10:29:50 2016 +0800 Committer: Zhao, Qingwen <qingwz...@apache.org> Committed: Wed Oct 19 10:29:50 2016 +0800 ---------------------------------------------------------------------- .../org/apache/eagle/alert/engine/runner/UnitTopologyRunner.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/668aea0c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/runner/UnitTopologyRunner.java ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/runner/UnitTopologyRunner.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/runner/UnitTopologyRunner.java index ec129fe..88cfb9b 100755 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/runner/UnitTopologyRunner.java +++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/runner/UnitTopologyRunner.java @@ -185,13 +185,13 @@ public class UnitTopologyRunner { * TODO potentially one route bolt may have multiple tasks, so that is field grouping by groupby fields * that means we need a separate field to become groupby field */ - builder.setBolt(boltName, routerBolts[i]).fieldsGrouping(spoutName, streamId, new Fields()); + builder.setBolt(boltName, routerBolts[i]).fieldsGrouping(spoutName, streamId, new Fields()).setNumTasks(1); } // connect router bolt and alert bolt, also define output streams for downstreaming alert publish bolt for (int i = 0; i < numOfAlertBolts; i++) { String boltName = alertBoltNamePrefix + i; - BoltDeclarer boltDeclarer = builder.setBolt(boltName, alertBolts[i]); + BoltDeclarer boltDeclarer = builder.setBolt(boltName, alertBolts[i]).setNumTasks(1); for (int j = 0; j < numOfRouterBolts; j++) { String streamId = StreamIdConversion.generateStreamIdBetween(streamRouterBoltNamePrefix + j, boltName); boltDeclarer.fieldsGrouping(streamRouterBoltNamePrefix + j, streamId, new Fields());
