You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eagle.apache.org by ra...@apache.org on 2016/11/09 02:43:09 UTC
[2/2] incubator-eagle git commit: EAGLE-756: make sure publish change
is sent to runtime bolts
EAGLE-756: make sure publish change is sent to runtime bolts
Author: Zeng, Bryant
Reviewer: ralphsu
This closes #630
Project: http://git-wip-us.apache.org/repos/asf/incubator-eagle/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-eagle/commit/6ec92894
Tree: http://git-wip-us.apache.org/repos/asf/incubator-eagle/tree/6ec92894
Diff: http://git-wip-us.apache.org/repos/asf/incubator-eagle/diff/6ec92894
Branch: refs/heads/master
Commit: 6ec928941364bcb565ec2b20d6da20336aaa3578
Parents: bd5f242
Author: mizeng <mi...@ebaysf.com>
Authored: Tue Nov 8 15:37:39 2016 -0800
Committer: Ralph, Su <su...@gmail.com>
Committed: Wed Nov 9 10:30:42 2016 +0800
----------------------------------------------------------------------
.../eagle/alert/engine/publisher/impl/AlertPublisherImpl.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/6ec92894/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/publisher/impl/AlertPublisherImpl.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/publisher/impl/AlertPublisherImpl.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/publisher/impl/AlertPublisherImpl.java
index a4038e7..7cb4a73 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/publisher/impl/AlertPublisherImpl.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/publisher/impl/AlertPublisherImpl.java
@@ -174,7 +174,10 @@ public class AlertPublisherImpl implements AlertPublisher {
addPublishmentPoliciesStreams(newPSPublishPluginMapping, newPolicies, newStreams, pubName);
}
Publishment newPub = afterModified.get(i);
- newPublishMap.get(pubName).update(newPub.getDedupIntervalMin(), newPub.getProperties());
+
+ // for updated publishment, need to init them too
+ AlertPublishPlugin newPlugin = AlertPublishPluginsFactory.createNotificationPlugin(newPub, config, conf);
+ newPublishMap.replace(pubName, newPlugin);
}
// now do the swap