Repository: falcon Updated Branches: refs/heads/master b568a050a -> 2dc3b1d77
FALCON-2041 Graphite notification plugin breaks if pipeline tag has s⦠â¦pace Author: Praveen Adlakha <[email protected]> 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 <[email protected]> Authored: Mon Jun 27 14:40:15 2016 +0530 Committer: Pallavi Rao <[email protected]> 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;
