eagle-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jinh...@apache.org
Subject incubator-eagle git commit: [EAGLE-674] fix grouping between AlertBolt and AlertPublisher
Date Mon, 24 Oct 2016 09:21:42 GMT
Repository: incubator-eagle
Updated Branches:
  refs/heads/master c15e7f814 -> 8a34294ec


[EAGLE-674] fix grouping between AlertBolt and AlertPublisher

Author: wujinhu <wujinhu920@126.com>

Closes #557 from wujinhu/EAGLE-673.


Project: http://git-wip-us.apache.org/repos/asf/incubator-eagle/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-eagle/commit/8a34294e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-eagle/tree/8a34294e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-eagle/diff/8a34294e

Branch: refs/heads/master
Commit: 8a34294ec604b42bee5dd99f40ba6e9f9fc498b5
Parents: c15e7f8
Author: wujinhu <wujinhu920@126.com>
Authored: Mon Oct 24 17:21:37 2016 +0800
Committer: wujinhu <wujinhu920@126.com>
Committed: Mon Oct 24 17:21:37 2016 +0800

----------------------------------------------------------------------
 .../org/apache/eagle/alert/engine/runner/UnitTopologyRunner.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/8a34294e/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 287d5db..3b40afd 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
@@ -205,7 +205,8 @@ public class UnitTopologyRunner {
         // connect alert bolt and alert publish bolt, this is the last bolt in the pipeline
         BoltDeclarer boltDeclarer = builder.setBolt(alertPublishBoltName, publisherBolt,
numOfPublishExecutors).setNumTasks(numOfPublishTasks);
         for (int i = 0; i < numOfAlertBolts; i++) {
-            boltDeclarer.fieldsGrouping(alertBoltNamePrefix + i, new Fields(AlertConstants.FIELD_0));
+            //boltDeclarer.fieldsGrouping(alertBoltNamePrefix + i, new Fields(AlertConstants.FIELD_0));
+            boltDeclarer.shuffleGrouping(alertBoltNamePrefix + i);
         }
 
         return builder.createTopology();


Mime
View raw message