Repository: atlas Updated Branches: refs/heads/branch-0.8 d28534083 -> a88df54f0
ATLAS-2195: fix to close a graph transaction left open during Atlas startup Signed-off-by: Madhan Neethiraj <[email protected]> (cherry picked from commit 48feaa3529cdcc29434d6f769c0247cc7d2de7b1) Project: http://git-wip-us.apache.org/repos/asf/atlas/repo Commit: http://git-wip-us.apache.org/repos/asf/atlas/commit/a88df54f Tree: http://git-wip-us.apache.org/repos/asf/atlas/tree/a88df54f Diff: http://git-wip-us.apache.org/repos/asf/atlas/diff/a88df54f Branch: refs/heads/branch-0.8 Commit: a88df54f0f6eb4f085ab270489402e0dcdab6a3c Parents: d285340 Author: Ashutosh Mestry <[email protected]> Authored: Thu Oct 12 17:15:40 2017 -0700 Committer: Madhan Neethiraj <[email protected]> Committed: Thu Oct 12 17:27:42 2017 -0700 ---------------------------------------------------------------------- .../atlas/repository/store/graph/v1/AtlasTypeDefGraphStoreV1.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/atlas/blob/a88df54f/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/AtlasTypeDefGraphStoreV1.java ---------------------------------------------------------------------- diff --git a/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/AtlasTypeDefGraphStoreV1.java b/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/AtlasTypeDefGraphStoreV1.java index 6e9ef68..6e428d0 100644 --- a/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/AtlasTypeDefGraphStoreV1.java +++ b/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/AtlasTypeDefGraphStoreV1.java @@ -21,6 +21,7 @@ import com.google.common.annotations.VisibleForTesting; import com.google.common.base.Preconditions; import org.apache.atlas.AtlasErrorCode; import org.apache.atlas.RequestContextV1; +import org.apache.atlas.annotation.GraphTransaction; import org.apache.atlas.exception.AtlasBaseException; import org.apache.atlas.listener.TypeDefChangeListener; import org.apache.atlas.model.typedef.*; @@ -95,7 +96,7 @@ public class AtlasTypeDefGraphStoreV1 extends AtlasTypeDefGraphStore { } @Override - @PostConstruct + @GraphTransaction public void init() throws AtlasBaseException { LOG.info("==> AtlasTypeDefGraphStoreV1.init()");
