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-2026 Null Pointer Exception in GraphiteNotificationPlugin for …
Date Thu, 16 Jun 2016 09:53:23 GMT
Repository: falcon
Updated Branches:
  refs/heads/master e7cdda742 -> d66185988


FALCON-2026 Null Pointer Exception in GraphiteNotificationPlugin for …

…deleted process

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

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 <adlakha.praveen@gmail.com>
Authored: Thu Jun 16 15:23:11 2016 +0530
Committer: Pallavi Rao <pallavi.rao@inmobi.com>
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";


Mime
View raw message