You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@atlas.apache.org by ma...@apache.org on 2017/10/07 16:33:56 UTC
atlas git commit: ATLAS-2192: notification consumer updates to handle
stale split messages (#2)
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 <ma...@apache.org>
Authored: Sat Oct 7 09:28:51 2017 -0700
Committer: Madhan Neethiraj <ma...@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");
}