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 <[email protected]> Authored: Sat Oct 7 09:28:51 2017 -0700 Committer: Madhan Neethiraj <[email protected]> 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"); }
