From ba71834f3f22ce2878dc544d818510704617f09e Mon Sep 17 00:00:00 2001 From: vaughn Date: Mon, 17 Apr 2023 15:18:56 +0800 Subject: [PATCH] chore: async remove left index should't effect query --- .../hugegraph/backend/tx/GraphTransaction.java | 14 ++++++++++++-- 1 file changed, 12 insertions(+), 2 deletions(-) diff --git a/hugegraph-core/src/main/java/org/apache/hugegraph/backend/tx/GraphTransaction.java b/hugegraph-core/src/main/java/org/apache/hugegraph/backend/tx/GraphTransaction.java index 42673daf47..cca5e2240f 100644 --- a/hugegraph-core/src/main/java/org/apache/hugegraph/backend/tx/GraphTransaction.java +++ b/hugegraph-core/src/main/java/org/apache/hugegraph/backend/tx/GraphTransaction.java @@ -1725,7 +1725,12 @@ private boolean rightResultFromIndexQuery(Query query, HugeElement elem) { * Both have correct and left index, wo should return true * but also needs to cleaned up left index */ - this.indexTx.asyncRemoveIndexLeft(cq, elem); + try { + this.indexTx.asyncRemoveIndexLeft(cq, elem); + } catch (Throwable e) { + LOG.warn("Failed to remove left index for query '{}', " + + "element '{}'", cq, elem, e); + } } /* Return true if: @@ -1737,7 +1742,12 @@ private boolean rightResultFromIndexQuery(Query query, HugeElement elem) { } if (cq.optimized() == OptimizedType.INDEX) { - this.indexTx.asyncRemoveIndexLeft(cq, elem); + try { + this.indexTx.asyncRemoveIndexLeft(cq, elem); + } catch (Throwable e) { + LOG.warn("Failed to remove left index for query '{}', " + + "element '{}'", cq, elem, e); + } } return false; }