fix(core): skip stale index entries

Author: contrueCT

hugegraph-server/hugegraph-core/src/main/java/org/apache/hugegraph/backend/tx/GraphIndexTransaction.java

@@ -685,8 +685,11 @@ private IdHolder doIndexQueryBatch(IndexLabel indexLabel,
                 Set<Id> ids = InsertionOrderUtil.newSet();
                 while ((batch == Query.NO_LIMIT || ids.size() < batch) &&
                        entries.hasNext()) {
-                    HugeIndex index = this.serializer.readIndex(graph(), query,
-                                                                entries.next());
+                    HugeIndex index = this.readMatchedIndex(indexLabel, query,
+                                                            entries.next());
+                    if (index == null) {
+                        continue;
+                    }
                     this.removeExpiredIndexIfNeeded(index, query.showExpired());
                     ids.addAll(index.elementIds());
                     Query.checkForceCapacity(ids.size());
@@ -727,8 +730,11 @@ private PageIds doIndexQueryOnce(IndexLabel indexLabel,
             Set<Id> ids = InsertionOrderUtil.newSet();
             entries = super.query(query).iterator();
             while (entries.hasNext()) {
-                HugeIndex index = this.serializer.readIndex(graph(), query,
-                                                            entries.next());
+                HugeIndex index = this.readMatchedIndex(indexLabel, query,
+                                                        entries.next());
+                if (index == null) {
+                    continue;
+                }
                 this.removeExpiredIndexIfNeeded(index, query.showExpired());
                 ids.addAll(index.elementIds());
                 if (query.reachLimit(ids.size())) {
@@ -756,6 +762,34 @@ private PageIds doIndexQueryOnce(IndexLabel indexLabel,
         }
     }
 
+    private HugeIndex readMatchedIndex(IndexLabel indexLabel,
+                                       ConditionQuery query,
+                                       BackendEntry entry) {
+        HugeIndex index;
+        try {
+            index = this.serializer.readIndex(graph(), query, entry);
+        } catch (IllegalArgumentException e) {
+            if (!missingIndexLabel(e)) {
+                throw e;
+            }
+            LOG.debug("Skip stale index entry with missing index label while " +
+                      "querying index label '{}'", indexLabel.id(), e);
+            return null;
+        }
+        if (!Objects.equals(index.indexLabelId(), indexLabel.id())) {
+            LOG.debug("Skip stale index entry of index label '{}' while " +
+                      "querying index label '{}'",
+                      index.indexLabelId(), indexLabel.id());
+            return null;
+        }
+        return index;
+    }
+
+    private static boolean missingIndexLabel(IllegalArgumentException e) {
+        String message = e.getMessage();
+        return message != null && message.contains("Undefined index label");
+    }
+
     @Watched(prefix = "index")
     private Set<MatchedIndex> collectMatchedIndexes(ConditionQuery query) {
         ISchemaTransaction schema = this.params().schemaTransaction();