[
https://issues.apache.org/jira/browse/EAGLE-690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15628021#comment-15628021
]
ASF GitHub Bot commented on EAGLE-690:
--------------------------------------
Github user puyulu commented on a diff in the pull request:
https://github.com/apache/incubator-eagle/pull/570#discussion_r86083566
--- Diff:
eagle-topology-check/eagle-topology-app/src/main/java/org/apache/eagle/topology/TopologyCheckApp.java
---
@@ -45,7 +63,16 @@ public StormTopology execute(Config config,
StormEnvironment environment) {
persistBoltName,
new TopologyDataPersistBolt(topologyCheckAppConfig),
topologyCheckAppConfig.dataExtractorConfig.numEntityPersistBolt
-
).setNumTasks(topologyCheckAppConfig.dataExtractorConfig.numEntityPersistBolt).shuffleGrouping(spoutName);
+
).setNumTasks(topologyCheckAppConfig.dataExtractorConfig.numEntityPersistBolt).shuffleGrouping(spoutName);
+
+ topologyBuilder.setBolt(
+ parseBoltName,
+ new HealthCheckParseBolt(),
+
topologyCheckAppConfig.dataExtractorConfig.numEntityPersistBolt).shuffleGrouping(persistBoltName);
+
+ logger.info("start to sink messsage to kafka");
--- End diff --
remove the incorrect comment
> Integrate topology health check with alert engine
> -------------------------------------------------
>
> Key: EAGLE-690
> URL: https://issues.apache.org/jira/browse/EAGLE-690
> Project: Eagle
> Issue Type: New Feature
> Affects Versions: v0.5.0
> Reporter: yupu
> Assignee: yupu
> Labels: features
> Fix For: v0.5.0
>
>
> Integrate topology health check with alert engine.
> It will send timestamp,tag,status to alert engine,when the node status is
> dead, alert engine will send the email to user
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
