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();