Repository: atlas Updated Branches: refs/heads/branch-1.0 de61f6abd -> 9291e53e8
ATLAS-2823: updated hooks to support asynchronous notifications - #2 (cherry picked from commit a7cd9ac38dd5dcd105a7d5a28c50e851ee0d29a0) Project: http://git-wip-us.apache.org/repos/asf/atlas/repo Commit: http://git-wip-us.apache.org/repos/asf/atlas/commit/9291e53e Tree: http://git-wip-us.apache.org/repos/asf/atlas/tree/9291e53e Diff: http://git-wip-us.apache.org/repos/asf/atlas/diff/9291e53e Branch: refs/heads/branch-1.0 Commit: 9291e53e8ccf63cd3b8c6827681df4cbb1baee22 Parents: de61f6a Author: Madhan Neethiraj <mad...@apache.org> Authored: Wed Aug 22 04:27:25 2018 -0700 Committer: Madhan Neethiraj <mad...@apache.org> Committed: Wed Aug 22 04:28:03 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/9291e53e/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
