atlas git commit: ATLAS-2834: Init authorizer when Atlas is in HA mode
Repository: atlas Updated Branches: refs/heads/branch-1.0 305854590 -> 5c0e00bbb ATLAS-2834: Init authorizer when Atlas is in HA mode (cherry picked from commit 70e10cc049f82243be0a3ace452c19b42476af6c) Project: http://git-wip-us.apache.org/repos/asf/atlas/repo Commit: http://git-wip-us.apache.org/repos/asf/atlas/commit/5c0e00bb Tree: http://git-wip-us.apache.org/repos/asf/atlas/tree/5c0e00bb Diff: http://git-wip-us.apache.org/repos/asf/atlas/diff/5c0e00bb Branch: refs/heads/branch-1.0 Commit: 5c0e00bbbdea50e715413d6134084d9ec00127ef Parents: 3058545 Author: apoorvnaik Authored: Tue Jul 31 07:06:17 2018 -0700 Committer: apoorvnaik Committed: Wed Aug 22 17:22:56 2018 -0700 -- .../store/bootstrap/AtlasTypeDefStoreInitializer.java | 6 ++ 1 file changed, 6 insertions(+) -- http://git-wip-us.apache.org/repos/asf/atlas/blob/5c0e00bb/repository/src/main/java/org/apache/atlas/repository/store/bootstrap/AtlasTypeDefStoreInitializer.java -- diff --git a/repository/src/main/java/org/apache/atlas/repository/store/bootstrap/AtlasTypeDefStoreInitializer.java b/repository/src/main/java/org/apache/atlas/repository/store/bootstrap/AtlasTypeDefStoreInitializer.java index 5fa37d9..e2b33bd 100644 --- a/repository/src/main/java/org/apache/atlas/repository/store/bootstrap/AtlasTypeDefStoreInitializer.java +++ b/repository/src/main/java/org/apache/atlas/repository/store/bootstrap/AtlasTypeDefStoreInitializer.java @@ -334,6 +334,12 @@ public class AtlasTypeDefStoreInitializer implements ActiveStateChangeHandler { atlasTypeDefStore.init(); loadBootstrapTypeDefs(); + +try { +AtlasAuthorizerFactory.getAtlasAuthorizer(); +} catch (Throwable t) { +LOG.error("AtlasTypeDefStoreInitializer.instanceIsActive(): Unable to obtain AtlasAuthorizer", t); +} } catch (AtlasBaseException e) { LOG.error("Failed to init after becoming active", e); }
atlas git commit: ATLAS-2834: Init authorizer when Atlas is in HA mode
Repository: atlas Updated Branches: refs/heads/master 35561d4ec -> 70e10cc04 ATLAS-2834: Init authorizer when Atlas is in HA mode Project: http://git-wip-us.apache.org/repos/asf/atlas/repo Commit: http://git-wip-us.apache.org/repos/asf/atlas/commit/70e10cc0 Tree: http://git-wip-us.apache.org/repos/asf/atlas/tree/70e10cc0 Diff: http://git-wip-us.apache.org/repos/asf/atlas/diff/70e10cc0 Branch: refs/heads/master Commit: 70e10cc049f82243be0a3ace452c19b42476af6c Parents: 35561d4 Author: apoorvnaik Authored: Tue Jul 31 07:06:17 2018 -0700 Committer: apoorvnaik Committed: Wed Aug 22 17:21:43 2018 -0700 -- .../store/bootstrap/AtlasTypeDefStoreInitializer.java | 6 ++ 1 file changed, 6 insertions(+) -- http://git-wip-us.apache.org/repos/asf/atlas/blob/70e10cc0/repository/src/main/java/org/apache/atlas/repository/store/bootstrap/AtlasTypeDefStoreInitializer.java -- diff --git a/repository/src/main/java/org/apache/atlas/repository/store/bootstrap/AtlasTypeDefStoreInitializer.java b/repository/src/main/java/org/apache/atlas/repository/store/bootstrap/AtlasTypeDefStoreInitializer.java index 5fa37d9..e2b33bd 100644 --- a/repository/src/main/java/org/apache/atlas/repository/store/bootstrap/AtlasTypeDefStoreInitializer.java +++ b/repository/src/main/java/org/apache/atlas/repository/store/bootstrap/AtlasTypeDefStoreInitializer.java @@ -334,6 +334,12 @@ public class AtlasTypeDefStoreInitializer implements ActiveStateChangeHandler { atlasTypeDefStore.init(); loadBootstrapTypeDefs(); + +try { +AtlasAuthorizerFactory.getAtlasAuthorizer(); +} catch (Throwable t) { +LOG.error("AtlasTypeDefStoreInitializer.instanceIsActive(): Unable to obtain AtlasAuthorizer", t); +} } catch (AtlasBaseException e) { LOG.error("Failed to init after becoming active", e); }
atlas git commit: ATLAS-2835: Regression: Classifications propagated from term is not removed during term-entity disassociation
Repository: atlas Updated Branches: refs/heads/branch-1.0 2f81c8953 -> 305854590 ATLAS-2835: Regression: Classifications propagated from term is not removed during term-entity disassociation (cherry picked from commit 35561d4ec0c92b5976b0cd4b241962833c96587b) Project: http://git-wip-us.apache.org/repos/asf/atlas/repo Commit: http://git-wip-us.apache.org/repos/asf/atlas/commit/30585459 Tree: http://git-wip-us.apache.org/repos/asf/atlas/tree/30585459 Diff: http://git-wip-us.apache.org/repos/asf/atlas/diff/30585459 Branch: refs/heads/branch-1.0 Commit: 305854590db35fe04bb3b4569205e66e1b0ff5e9 Parents: 2f81c89 Author: Sarath Subramanian Authored: Wed Aug 22 16:22:08 2018 -0700 Committer: Sarath Subramanian Committed: Wed Aug 22 16:33:40 2018 -0700 -- .../apache/atlas/repository/store/graph/v1/DeleteHandlerV1.java | 3 +++ 1 file changed, 3 insertions(+) -- http://git-wip-us.apache.org/repos/asf/atlas/blob/30585459/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/DeleteHandlerV1.java -- diff --git a/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/DeleteHandlerV1.java b/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/DeleteHandlerV1.java index 98cfc78..16b193d 100644 --- a/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/DeleteHandlerV1.java +++ b/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/DeleteHandlerV1.java @@ -153,6 +153,9 @@ public abstract class DeleteHandlerV1 { continue; } +// re-evaluate tag propagation +removeTagPropagation(edge); + deleteEdge(edge, isInternal || forceDelete); } }
atlas git commit: ATLAS-2835: Regression: Classifications propagated from term is not removed during term-entity disassociation
Repository: atlas Updated Branches: refs/heads/master 36080c337 -> 35561d4ec ATLAS-2835: Regression: Classifications propagated from term is not removed during term-entity disassociation Project: http://git-wip-us.apache.org/repos/asf/atlas/repo Commit: http://git-wip-us.apache.org/repos/asf/atlas/commit/35561d4e Tree: http://git-wip-us.apache.org/repos/asf/atlas/tree/35561d4e Diff: http://git-wip-us.apache.org/repos/asf/atlas/diff/35561d4e Branch: refs/heads/master Commit: 35561d4ec0c92b5976b0cd4b241962833c96587b Parents: 36080c3 Author: Sarath Subramanian Authored: Wed Aug 22 16:22:08 2018 -0700 Committer: Sarath Subramanian Committed: Wed Aug 22 16:22:08 2018 -0700 -- .../apache/atlas/repository/store/graph/v1/DeleteHandlerV1.java | 3 +++ 1 file changed, 3 insertions(+) -- http://git-wip-us.apache.org/repos/asf/atlas/blob/35561d4e/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/DeleteHandlerV1.java -- diff --git a/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/DeleteHandlerV1.java b/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/DeleteHandlerV1.java index 98cfc78..16b193d 100644 --- a/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/DeleteHandlerV1.java +++ b/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/DeleteHandlerV1.java @@ -153,6 +153,9 @@ public abstract class DeleteHandlerV1 { continue; } +// re-evaluate tag propagation +removeTagPropagation(edge); + deleteEdge(edge, isInternal || forceDelete); } }
atlas git commit: ATLAS-2817: Change janusgraph artifactId
Repository: atlas Updated Branches: refs/heads/branch-1.0 165d6cfcc -> 2f81c8953 ATLAS-2817: Change janusgraph artifactId (cherry picked from commit 36080c33790c3d363212c374d4e6e88c5c1cf98f) Project: http://git-wip-us.apache.org/repos/asf/atlas/repo Commit: http://git-wip-us.apache.org/repos/asf/atlas/commit/2f81c895 Tree: http://git-wip-us.apache.org/repos/asf/atlas/tree/2f81c895 Diff: http://git-wip-us.apache.org/repos/asf/atlas/diff/2f81c895 Branch: refs/heads/branch-1.0 Commit: 2f81c8953054ddf983f80c9b17cc3c615e737095 Parents: 165d6cf Author: apoorvnaik Authored: Tue Jul 31 07:06:17 2018 -0700 Committer: apoorvnaik Committed: Wed Aug 22 12:25:28 2018 -0700 -- graphdb/janus/pom.xml | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) -- http://git-wip-us.apache.org/repos/asf/atlas/blob/2f81c895/graphdb/janus/pom.xml -- diff --git a/graphdb/janus/pom.xml b/graphdb/janus/pom.xml index 2d64ea8..ab59d01 100644 --- a/graphdb/janus/pom.xml +++ b/graphdb/janus/pom.xml @@ -68,7 +68,7 @@ org.janusgraph -janusgraph-core +janusgraph-server ${janus.version} @@ -219,7 +219,6 @@ ${tinkerpop.version} - org.testng testng
atlas git commit: ATLAS-2817: Change janusgraph artifactId
Repository: atlas Updated Branches: refs/heads/master be05196b3 -> 36080c337 ATLAS-2817: Change janusgraph artifactId Project: http://git-wip-us.apache.org/repos/asf/atlas/repo Commit: http://git-wip-us.apache.org/repos/asf/atlas/commit/36080c33 Tree: http://git-wip-us.apache.org/repos/asf/atlas/tree/36080c33 Diff: http://git-wip-us.apache.org/repos/asf/atlas/diff/36080c33 Branch: refs/heads/master Commit: 36080c33790c3d363212c374d4e6e88c5c1cf98f Parents: be05196 Author: apoorvnaik Authored: Tue Jul 31 07:06:17 2018 -0700 Committer: apoorvnaik Committed: Wed Aug 22 12:23:20 2018 -0700 -- graphdb/janus/pom.xml | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) -- http://git-wip-us.apache.org/repos/asf/atlas/blob/36080c33/graphdb/janus/pom.xml -- diff --git a/graphdb/janus/pom.xml b/graphdb/janus/pom.xml index 89b331f..cd5c82e 100644 --- a/graphdb/janus/pom.xml +++ b/graphdb/janus/pom.xml @@ -68,7 +68,7 @@ org.janusgraph -janusgraph-core +janusgraph-server ${janus.version} @@ -219,7 +219,6 @@ ${tinkerpop.version} - org.testng testng
atlas git commit: ATLAS-2832: Replace Titan with JanusGraph in the architecture diagram image.
Repository: atlas Updated Branches: refs/heads/branch-1.0 9291e53e8 -> 165d6cfcc ATLAS-2832: Replace Titan with JanusGraph in the architecture diagram image. Signed-off-by: nixonrodrigues Project: http://git-wip-us.apache.org/repos/asf/atlas/repo Commit: http://git-wip-us.apache.org/repos/asf/atlas/commit/165d6cfc Tree: http://git-wip-us.apache.org/repos/asf/atlas/tree/165d6cfc Diff: http://git-wip-us.apache.org/repos/asf/atlas/diff/165d6cfc Branch: refs/heads/branch-1.0 Commit: 165d6cfccac83bd74876cb0cda8fe159490e465e Parents: 9291e53 Author: Abhishek Kadam Authored: Wed Aug 22 18:17:59 2018 +0530 Committer: nixonrodrigues Committed: Wed Aug 22 19:18:31 2018 +0530 -- .../resources/images/twiki/architecture.png | Bin 315403 -> 172567 bytes 1 file changed, 0 insertions(+), 0 deletions(-) -- http://git-wip-us.apache.org/repos/asf/atlas/blob/165d6cfc/docs/src/site/resources/images/twiki/architecture.png -- diff --git a/docs/src/site/resources/images/twiki/architecture.png b/docs/src/site/resources/images/twiki/architecture.png old mode 100755 new mode 100644 index 22d8787..22a0f66 Binary files a/docs/src/site/resources/images/twiki/architecture.png and b/docs/src/site/resources/images/twiki/architecture.png differ
atlas git commit: ATLAS-2832: Replace Titan with JanusGraph in the architecture diagram image.
Repository: atlas Updated Branches: refs/heads/master a7cd9ac38 -> be05196b3 ATLAS-2832: Replace Titan with JanusGraph in the architecture diagram image. Project: http://git-wip-us.apache.org/repos/asf/atlas/repo Commit: http://git-wip-us.apache.org/repos/asf/atlas/commit/be05196b Tree: http://git-wip-us.apache.org/repos/asf/atlas/tree/be05196b Diff: http://git-wip-us.apache.org/repos/asf/atlas/diff/be05196b Branch: refs/heads/master Commit: be05196b317227d7032cd7295060ca1985056acc Parents: a7cd9ac Author: Abhishek Kadam Authored: Wed Aug 22 18:17:59 2018 +0530 Committer: nixonrodrigues Committed: Wed Aug 22 19:10:51 2018 +0530 -- .../resources/images/twiki/architecture.png | Bin 315403 -> 172567 bytes 1 file changed, 0 insertions(+), 0 deletions(-) -- http://git-wip-us.apache.org/repos/asf/atlas/blob/be05196b/docs/src/site/resources/images/twiki/architecture.png -- diff --git a/docs/src/site/resources/images/twiki/architecture.png b/docs/src/site/resources/images/twiki/architecture.png old mode 100755 new mode 100644 index 22d8787..22a0f66 Binary files a/docs/src/site/resources/images/twiki/architecture.png and b/docs/src/site/resources/images/twiki/architecture.png differ
atlas git commit: ATLAS-2823: updated hooks to support asynchronous notifications - #2
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 Authored: Wed Aug 22 04:27:25 2018 -0700 Committer: Madhan Neethiraj 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, 1); int queueSize = atlasProperties.getInt(ATLAS_NOTIFICATION_ASYNCHRONOUS_QUEUE_SIZE, 1); 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
atlas git commit: ATLAS-2823: updated hooks to support asynchronous notifications - #2
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 Authored: Wed Aug 22 04:27:25 2018 -0700 Committer: Madhan Neethiraj 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, 1); int queueSize = atlasProperties.getInt(ATLAS_NOTIFICATION_ASYNCHRONOUS_QUEUE_SIZE, 1); 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
atlas git commit: ATLAS-2823: updated hooks to support asynchronous notifications - #2
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 Authored: Wed Aug 22 04:15:53 2018 -0700 Committer: Madhan Neethiraj 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, 1); int queueSize = atlasProperties.getInt(ATLAS_NOTIFICATION_ASYNCHRONOUS_QUEUE_SIZE, 1); 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