Repository: falcon Updated Branches: refs/heads/master e7cdda742 -> d66185988
FALCON-2026 Null Pointer Exception in GraphiteNotificationPlugin for ⦠â¦deleted process Author: Praveen Adlakha <[email protected]> Reviewers: @pallavi-rao Closes #184 from PraveenAdlakha/2026 Project: http://git-wip-us.apache.org/repos/asf/falcon/repo Commit: http://git-wip-us.apache.org/repos/asf/falcon/commit/d6618598 Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/d6618598 Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/d6618598 Branch: refs/heads/master Commit: d66185988ae0aa60768b272759d2312d724976f9 Parents: e7cdda7 Author: Praveen Adlakha <[email protected]> Authored: Thu Jun 16 15:23:11 2016 +0530 Committer: Pallavi Rao <[email protected]> Committed: Thu Jun 16 15:23:11 2016 +0530 ---------------------------------------------------------------------- .../java/org/apache/falcon/plugin/GraphiteNotificationPlugin.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/falcon/blob/d6618598/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 abe6777..e35955d 100644 --- a/prism/src/main/java/org/apache/falcon/plugin/GraphiteNotificationPlugin.java +++ b/prism/src/main/java/org/apache/falcon/plugin/GraphiteNotificationPlugin.java @@ -52,7 +52,8 @@ public class GraphiteNotificationPlugin implements MonitoringPlugin { String prefix = StartupProperties.get().getProperty("falcon.graphite.prefix"); String separator = "."; LOG.debug("message:" + message.getAction()); - if (entityType.equalsIgnoreCase(EntityType.PROCESS.name())) { + if (entityType.equalsIgnoreCase(EntityType.PROCESS.name()) + && ConfigurationStore.get().get(EntityType.PROCESS, entityName) != null) { Entity entity = ConfigurationStore.get().get(EntityType.PROCESS, entityName); Process process = (Process) entity; String pipeline = StringUtils.isNotBlank(process.getPipelines()) ? process.getPipelines() : "default";
