This is an automated email from the ASF dual-hosted git repository.

pinal pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/atlas.git


The following commit(s) were added to refs/heads/master by this push:
     new 493560073 ATLAS-5171: Regression: Reindexing is failing (#494)
493560073 is described below

commit 493560073c1edaf7253b6fded9e1a349abda683f
Author: Pinal Shah <[email protected]>
AuthorDate: Wed Jan 14 18:17:52 2026 +0530

    ATLAS-5171: Regression: Reindexing is failing (#494)
    
    ---------
    
    Co-authored-by: Pinal Shah <[email protected]>
---
 .../atlas/repository/graphdb/janus/AtlasJanusGraphManagement.java | 8 ++++++--
 .../repository/graphdb/janus/AtlasJanusGraphManagementTest.java   | 3 +++
 2 files changed, 9 insertions(+), 2 deletions(-)

diff --git 
a/graphdb/janus/src/main/java/org/apache/atlas/repository/graphdb/janus/AtlasJanusGraphManagement.java
 
b/graphdb/janus/src/main/java/org/apache/atlas/repository/graphdb/janus/AtlasJanusGraphManagement.java
index a1c6cf87e..c68f7ce05 100644
--- 
a/graphdb/janus/src/main/java/org/apache/atlas/repository/graphdb/janus/AtlasJanusGraphManagement.java
+++ 
b/graphdb/janus/src/main/java/org/apache/atlas/repository/graphdb/janus/AtlasJanusGraphManagement.java
@@ -431,13 +431,17 @@ public class AtlasJanusGraphManagement implements 
AtlasGraphManagement {
     }
 
     private void rollback() {
-        management.rollback();
+        if (management != null && management.isOpen()) {
+            management.rollback();
+        }
     }
 
     private void commit() {
         graph.addMultiProperties(newMultProperties);
         newMultProperties.clear();
-        management.commit();
+        if (management != null && management.isOpen()) {
+            management.commit();
+        }
     }
 
     private static void checkName(String name) {
diff --git 
a/graphdb/janus/src/test/java/org/apache/atlas/repository/graphdb/janus/AtlasJanusGraphManagementTest.java
 
b/graphdb/janus/src/test/java/org/apache/atlas/repository/graphdb/janus/AtlasJanusGraphManagementTest.java
index ec5201206..0c9d1dc69 100644
--- 
a/graphdb/janus/src/test/java/org/apache/atlas/repository/graphdb/janus/AtlasJanusGraphManagementTest.java
+++ 
b/graphdb/janus/src/test/java/org/apache/atlas/repository/graphdb/janus/AtlasJanusGraphManagementTest.java
@@ -524,6 +524,7 @@ public class AtlasJanusGraphManagementTest {
         
when(mockPropertyKeyMaker.cardinality(any(Cardinality.class))).thenReturn(mockPropertyKeyMaker);
         when(mockPropertyKeyMaker.make()).thenReturn(mockJanusPropertyKey);
         when(mockJanusPropertyKey.name()).thenReturn("multiProp");
+        when(mockJanusManagement.isOpen()).thenReturn(true);
 
         // Create a multi-cardinality property to add to newMultProperties
         management.makePropertyKey("multiProp", String.class, 
AtlasCardinality.SET);
@@ -538,6 +539,8 @@ public class AtlasJanusGraphManagementTest {
 
     @Test
     public void testRollback() throws Exception {
+        when(mockJanusManagement.isOpen()).thenReturn(true);
+
         management.setIsSuccess(false);
         management.close();
 

Reply via email to