chore: async remove left index should't effect query

apache · Apr 19, 2023 · ce4f402 · ce4f402
1 parent 7b6a4bd
commit ce4f402
Show file tree

Hide file tree

Showing 2 changed files with 22 additions and 2 deletions.
diff --git a/hugegraph-api/pom.xml b/hugegraph-api/pom.xml
@@ -35,10 +35,20 @@
             <version>${revision}</version>
         </dependency>
 
+        <dependency>
+            <groupId>io.grpc</groupId>
+            <artifactId>grpc-netty-shaded</artifactId>
+            <version>1.47.0</version>
+        </dependency>
+
         <dependency>
             <groupId>org.apache.hugegraph</groupId>
             <artifactId>hugegraph-rpc</artifactId>
             <exclusions>
+                <exclusion>
+                    <groupId>io.grpc</groupId>
+                    <artifactId>grpc-netty-shaded</artifactId>
+                </exclusion>
                 <!-- conflict with jraft -->
                 <exclusion>
                     <groupId>com.alipay.sofa</groupId>

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
@@ -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;
     }