Skip to content

A
atlas
Commit 8663eb1d by Ashutosh Mestry Committed by Madhan Neethiraj
Options

ATLAS-2195: fix to close trasaction left open while queries index keys (#2)

Signed-off-by: 's avatarMadhan Neethiraj <madhan@apache.org>
parent 59f83fc0
Showing with 21 additions and 11 deletions
repository/src/main/java/org/apache/atlas/repository/graph/GraphBackedSearchIndexer.java
...@@ -261,23 +261,33 @@ public class GraphBackedSearchIndexer implements SearchIndexer, ActiveStateChang ...@@ -261,23 +261,33 @@ public class GraphBackedSearchIndexer implements SearchIndexer, ActiveStateChang
try { try {
management = provider.get().getManagementSystem(); management = provider.get().getManagementSystem();
} catch (RepositoryException excp) {
LOG.error("failed to get indexedKeys from graph", excp);
}
if (management != null) { if (management != null) {
AtlasGraphIndex vertexIndex = management.getGraphIndex(Constants.VERTEX_INDEX); AtlasGraphIndex vertexIndex = management.getGraphIndex(Constants.VERTEX_INDEX);
if (vertexIndex != null) {
recomputeIndexedKeys = false;
if (vertexIndex != null) { Set<String> indexKeys = new HashSet<>();
recomputeIndexedKeys = false;
Set<String> indexKeys = new HashSet<>(); for (AtlasPropertyKey fieldKey : vertexIndex.getFieldKeys()) {
indexKeys.add(fieldKey.getName());
}
for (AtlasPropertyKey fieldKey : vertexIndex.getFieldKeys()) { vertexIndexKeys = indexKeys;
indexKeys.add(fieldKey.getName());
} }
vertexIndexKeys = indexKeys; management.commit();
}
} catch (Exception excp) {
LOG.error("getVertexIndexKeys(): failed to get indexedKeys from graph", excp);
if (management != null) {
try {
management.rollback();
} catch (Exception e) {
LOG.error("getVertexIndexKeys(): rollback failed", e);
}
} }
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment