falcon-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From venkat...@apache.org
Subject [2/2] git commit: FALCON-354 Bug when MetadataMappingService is not configured as one of the application services. Contributed by Venkatesh Seetharam
Date Fri, 14 Mar 2014 04:06:31 GMT
FALCON-354 Bug when MetadataMappingService is not configured as one of the
    application services. Contributed by Venkatesh Seetharam


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

Branch: refs/heads/master
Commit: bb55a2c9f489c21f9c0d2e9faf1e4ed1bce8c176
Parents: 1e7aa8e
Author: Venkatesh Seetharam <venkatesh@hortonworks.com>
Authored: Thu Mar 13 21:06:21 2014 -0700
Committer: Venkatesh Seetharam <venkatesh@hortonworks.com>
Committed: Thu Mar 13 21:06:21 2014 -0700

----------------------------------------------------------------------
 CHANGES.txt                                                    | 3 +++
 .../java/org/apache/falcon/service/FalconTopicSubscriber.java  | 6 ++++--
 2 files changed, 7 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/bb55a2c9/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index f58750e..b1f8cb1 100755
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -145,6 +145,9 @@ Trunk (Unreleased)
 
     FALCON-336 Fix check style error - builds fail (Venkatesh Seetharam)
 
+    FALCON-354 Bug when MetadataMappingService is not configured as one of the
+    application services. (Venkatesh Seetharam)
+
 Release Version: 0.4-incubating
 
    NEW FEATURES

http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/bb55a2c9/prism/src/main/java/org/apache/falcon/service/FalconTopicSubscriber.java
----------------------------------------------------------------------
diff --git a/prism/src/main/java/org/apache/falcon/service/FalconTopicSubscriber.java b/prism/src/main/java/org/apache/falcon/service/FalconTopicSubscriber.java
index 64143e9..e780c18 100644
--- a/prism/src/main/java/org/apache/falcon/service/FalconTopicSubscriber.java
+++ b/prism/src/main/java/org/apache/falcon/service/FalconTopicSubscriber.java
@@ -154,8 +154,10 @@ public class FalconTopicSubscriber implements MessageListener, ExceptionListener
 
     private void notifyMetadataMappingService(String entityName, String operation,
                                               String logDir) throws FalconException {
-        MetadataMappingService service = Services.get().getService(MetadataMappingService.SERVICE_NAME);
-        service.onSuccessfulWorkflowCompletion(entityName, operation, logDir);
+        if (Services.get().isRegistered(MetadataMappingService.SERVICE_NAME)) {
+            MetadataMappingService service = Services.get().getService(MetadataMappingService.SERVICE_NAME);
+            service.onSuccessfulWorkflowCompletion(entityName, operation, logDir);
+        }
     }
 
     private void debug(MapMessage mapMessage) throws JMSException {


Mime
View raw message