atlas-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mad...@apache.org
Subject atlas git commit: ATLAS-2192: notification consumer updates to handle stale split messages (#2)
Date Sat, 07 Oct 2017 16:33:56 GMT
Repository: atlas
Updated Branches:
  refs/heads/master 9a8c71254 -> 6a18b5c65


ATLAS-2192: notification consumer updates to handle stale split messages (#2)


Project: http://git-wip-us.apache.org/repos/asf/atlas/repo
Commit: http://git-wip-us.apache.org/repos/asf/atlas/commit/6a18b5c6
Tree: http://git-wip-us.apache.org/repos/asf/atlas/tree/6a18b5c6
Diff: http://git-wip-us.apache.org/repos/asf/atlas/diff/6a18b5c6

Branch: refs/heads/master
Commit: 6a18b5c65257a7905b4a50612e9e2c8978bfaa6d
Parents: 9a8c712
Author: Madhan Neethiraj <madhan@apache.org>
Authored: Sat Oct 7 09:28:51 2017 -0700
Committer: Madhan Neethiraj <madhan@apache.org>
Committed: Sat Oct 7 09:28:51 2017 -0700

----------------------------------------------------------------------
 .../src/main/java/org/apache/atlas/hook/AtlasHook.java   | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/atlas/blob/6a18b5c6/notification/src/main/java/org/apache/atlas/hook/AtlasHook.java
----------------------------------------------------------------------
diff --git a/notification/src/main/java/org/apache/atlas/hook/AtlasHook.java b/notification/src/main/java/org/apache/atlas/hook/AtlasHook.java
index 4829221..38f3208 100644
--- a/notification/src/main/java/org/apache/atlas/hook/AtlasHook.java
+++ b/notification/src/main/java/org/apache/atlas/hook/AtlasHook.java
@@ -85,7 +85,16 @@ public abstract class AtlasHook {
 
         notificationRetryInterval = atlasProperties.getInt(ATLAS_NOTIFICATION_RETRY_INTERVAL,
1000);
         notificationInterface = NotificationProvider.get();
-        notificationInterface.setCurrentUser(getUser());
+
+        String currentUser = "";
+
+        try {
+            currentUser = getUser();
+        } catch (Exception excp) {
+            LOG.warn("Error in determining current user", excp);
+        }
+
+        notificationInterface.setCurrentUser(currentUser);
 
         LOG.info("Created Atlas Hook");
     }


Mime
View raw message