This is an automated email from the ASF dual-hosted git repository. amestry pushed a commit to branch branch-2.0 in repository https://gitbox.apache.org/repos/asf/atlas.git
commit 998e762c643b8628e0f46f8aff92777e9942fd52 Author: Ashutosh Mestry <[email protected]> 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());
