Repository: atlas Updated Branches: refs/heads/branch-0.8 d1f491112 -> b432547b8
ATLAS-2823: updated hooks to support asynchronous notifications - #2 Project: http://git-wip-us.apache.org/repos/asf/atlas/repo Commit: http://git-wip-us.apache.org/repos/asf/atlas/commit/b432547b Tree: http://git-wip-us.apache.org/repos/asf/atlas/tree/b432547b Diff: http://git-wip-us.apache.org/repos/asf/atlas/diff/b432547b Branch: refs/heads/branch-0.8 Commit: b432547b8c7fa498dbecf41a36661029620f1691 Parents: d1f4911 Author: Madhan Neethiraj <mad...@apache.org> Authored: Wed Aug 22 04:15:53 2018 -0700 Committer: Madhan Neethiraj <mad...@apache.org> Committed: Wed Aug 22 04:15:53 2018 -0700 ---------------------------------------------------------------------- notification/src/main/java/org/apache/atlas/hook/AtlasHook.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/atlas/blob/b432547b/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 8d24035..d4b0715 100644 --- a/notification/src/main/java/org/apache/atlas/hook/AtlasHook.java +++ b/notification/src/main/java/org/apache/atlas/hook/AtlasHook.java @@ -119,13 +119,13 @@ public abstract class AtlasHook { if (isAsync) { int minThreads = atlasProperties.getInt(ATLAS_NOTIFICATION_ASYNCHRONOUS_MIN_THREADS, 1); - int maxThreads = atlasProperties.getInt(ATLAS_NOTIFICATION_ASYNCHRONOUS_MAX_THREADS, 5); + int maxThreads = atlasProperties.getInt(ATLAS_NOTIFICATION_ASYNCHRONOUS_MAX_THREADS, 1); long keepAliveTimeMs = atlasProperties.getLong(ATLAS_NOTIFICATION_ASYNCHRONOUS_KEEP_ALIVE_TIME_MS, 10000); int queueSize = atlasProperties.getInt(ATLAS_NOTIFICATION_ASYNCHRONOUS_QUEUE_SIZE, 10000); executor = new ThreadPoolExecutor(minThreads, maxThreads, keepAliveTimeMs, TimeUnit.MILLISECONDS, new LinkedBlockingDeque<>(queueSize), - new ThreadFactoryBuilder().setNameFormat("Atlas Notifier %d").build()); + new ThreadFactoryBuilder().setNameFormat("Atlas Notifier %d").setDaemon(true).build()); ShutdownHookManager.get().addShutdownHook(new Thread() { @Override
