[fix][dingo-executor] Fix text search error within transaction

dingodb · Oct 24, 2024 · 2762d59 · 2762d59
1 parent de25143
commit 2762d59
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/dingo-exec/src/main/java/io/dingodb/exec/operator/TxnPartDocumentOperator.java b/dingo-exec/src/main/java/io/dingodb/exec/operator/TxnPartDocumentOperator.java
@@ -34,7 +34,6 @@
 import io.dingodb.store.api.StoreService;
 import io.dingodb.store.api.transaction.data.DocumentSearchParameter;
 import io.dingodb.store.api.transaction.data.DocumentValue;
-import io.dingodb.store.api.transaction.data.DocumentWithId;
 import io.dingodb.store.api.transaction.data.DocumentWithScore;
 import io.dingodb.store.api.transaction.data.ScalarField;
 import lombok.extern.slf4j.Slf4j;
@@ -99,11 +98,12 @@ public class TxnPartDocumentOperator extends FilterProjectSourceOperator {
                     if (local != null) {
                         while (local.hasNext()) {
                             Object[] objects = local.next();
-                            results.add(objects);
+                            if(objects[priTuples.length-1] instanceof Float){
+                                results.add(objects);
+                            }
                         }
                         continue;
                     }
-
                     StoreInstance storeInstance = StoreService.getDefault().getInstance(param.getTableId(), regionId);
                     KeyValue keyValue = storeInstance.txnGet(param.getScanTs(), tableData.getKey(), param.getTimeOut());
                     if (keyValue == null || keyValue.getValue() == null) {