commit 6a18b5c65257a7905b4a50612e9e2c8978bfaa6d
author Madhan Neethiraj <madhan@apache.org> Sat Oct 07 09:28:51 2017 -0700
committer Madhan Neethiraj <madhan@apache.org> Sat Oct 07 09:28:51 2017 -0700
tree 42c65d129079b31b84738c88695e0e06a7ed1ffe
parent 9a8c71254c70a0e70241c8b9c8892603ecb03e7c

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

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 @@
 
         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");
     }