falcon-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pall...@apache.org
Subject falcon git commit: FALCON-2041 Graphite notification plugin breaks if pipeline tag has s…
Date Mon, 27 Jun 2016 09:10:13 GMT
Repository: falcon
Updated Branches:
  refs/heads/master b568a050a -> 2dc3b1d77


FALCON-2041 Graphite notification plugin breaks if pipeline tag has s…

…pace

Author: Praveen Adlakha <adlakha.praveen@gmail.com>

Reviewers: @pallavi-rao

Closes #195 from PraveenAdlakha/2041


Project: http://git-wip-us.apache.org/repos/asf/falcon/repo
Commit: http://git-wip-us.apache.org/repos/asf/falcon/commit/2dc3b1d7
Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/2dc3b1d7
Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/2dc3b1d7

Branch: refs/heads/master
Commit: 2dc3b1d778a4991536705878e4e16299fc21a1dc
Parents: b568a05
Author: Praveen Adlakha <adlakha.praveen@gmail.com>
Authored: Mon Jun 27 14:40:15 2016 +0530
Committer: Pallavi Rao <pallavi.rao@inmobi.com>
Committed: Mon Jun 27 14:40:15 2016 +0530

----------------------------------------------------------------------
 .../java/org/apache/falcon/plugin/GraphiteNotificationPlugin.java   | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/falcon/blob/2dc3b1d7/prism/src/main/java/org/apache/falcon/plugin/GraphiteNotificationPlugin.java
----------------------------------------------------------------------
diff --git a/prism/src/main/java/org/apache/falcon/plugin/GraphiteNotificationPlugin.java
b/prism/src/main/java/org/apache/falcon/plugin/GraphiteNotificationPlugin.java
index e35955d..881f8ce 100644
--- a/prism/src/main/java/org/apache/falcon/plugin/GraphiteNotificationPlugin.java
+++ b/prism/src/main/java/org/apache/falcon/plugin/GraphiteNotificationPlugin.java
@@ -57,6 +57,7 @@ public class GraphiteNotificationPlugin implements MonitoringPlugin {
                 Entity entity = ConfigurationStore.get().get(EntityType.PROCESS, entityName);
                 Process process = (Process) entity;
                 String pipeline =  StringUtils.isNotBlank(process.getPipelines()) ? process.getPipelines()
: "default";
+                pipeline = pipeline.replaceAll(" ", "-");
 
                 if ((message.getAction().equals("wf-instance-succeeded"))) {
                     Long timeTaken =  message.getExecutionTime() / 1000000000;


Mime
View raw message