Repository: atlas Updated Branches: refs/heads/master 4b2324f36 -> a7cd9ac38
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/a7cd9ac3 Tree: http://git-wip-us.apache.org/repos/asf/atlas/tree/a7cd9ac3 Diff: http://git-wip-us.apache.org/repos/asf/atlas/diff/a7cd9ac3 Branch: refs/heads/master Commit: a7cd9ac38dd5dcd105a7d5a28c50e851ee0d29a0 Parents: 4b2324f Author: Madhan Neethiraj <[email protected]> Authored: Wed Aug 22 04:27:25 2018 -0700 Committer: Madhan Neethiraj <[email protected]> Committed: Wed Aug 22 04:27:25 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/a7cd9ac3/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 406f679..31874af 100644 --- a/notification/src/main/java/org/apache/atlas/hook/AtlasHook.java +++ b/notification/src/main/java/org/apache/atlas/hook/AtlasHook.java @@ -113,13 +113,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
