[atlas] branch master updated: ATLAS-3941: Notification Consumer: Reduce pause time on AtlasSchemaViolation exception.

[amestry]

This is an automated email from the ASF dual-hosted git repository.

amestry pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/atlas.git


The following commit(s) were added to refs/heads/master by this push:
     new f4b1c42  ATLAS-3941: Notification Consumer: Reduce pause time on 
AtlasSchemaViolation exception.
f4b1c42 is described below

commit f4b1c4294f37a53d2041fb925dc43dba5f166b67
Author: Ashutosh Mestry <ames...@cloudera.com>
AuthorDate: Wed Nov 18 13:53:38 2020 -0800

    ATLAS-3941: Notification Consumer: Reduce pause time on 
AtlasSchemaViolation exception.
---
 .../org/apache/atlas/notification/NotificationHookConsumer.java    | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/webapp/src/main/java/org/apache/atlas/notification/NotificationHookConsumer.java
 
b/webapp/src/main/java/org/apache/atlas/notification/NotificationHookConsumer.java
index f02c05f..0e58dac 100644
--- 
a/webapp/src/main/java/org/apache/atlas/notification/NotificationHookConsumer.java
+++ 
b/webapp/src/main/java/org/apache/atlas/notification/NotificationHookConsumer.java
@@ -809,9 +809,10 @@ public class NotificationHookConsumer implements Service, 
ActiveStateChangeHandl
                                 recordFailedMessages();
                             }
                             return;
-                        } else if (e instanceof 
org.apache.atlas.repository.graphdb.AtlasSchemaViolationException
-                                        || 
exceptionClassName.equals(EXCEPTION_CLASS_NAME_JANUSGRAPH_EXCEPTION)
-                                        || 
exceptionClassName.equals(EXCEPTION_CLASS_NAME_PERMANENTLOCKING_EXCEPTION)) {
+                        } else if (e instanceof 
org.apache.atlas.repository.graphdb.AtlasSchemaViolationException) {
+                            LOG.warn("{}: Continuing: {}", exceptionClassName, 
e.getMessage());
+                        } else if 
(exceptionClassName.equals(EXCEPTION_CLASS_NAME_JANUSGRAPH_EXCEPTION)
+                                || 
exceptionClassName.equals(EXCEPTION_CLASS_NAME_PERMANENTLOCKING_EXCEPTION)) {
                             LOG.warn("{}: Pausing & retry: Try: {}: Pause: {} 
ms. {}",
                                     exceptionClassName, numRetries, 
adaptiveWaiter.waitDuration, e.getMessage());