[feat][executor] Change schemas for fixing the wrong column index whe…

…n decode vector value buf.
dingodb · Dec 26, 2024 · c1a4e63 · c1a4e63
1 parent a2ae488
commit c1a4e63
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/dingo-exec/src/main/java/io/dingodb/exec/operator/TxnPartVectorOperator.java b/dingo-exec/src/main/java/io/dingodb/exec/operator/TxnPartVectorOperator.java
@@ -63,7 +63,7 @@ public class TxnPartVectorOperator extends FilterProjectSourceOperator {
         String distanceType = param.getDistanceType();
         KeyValueCodec tableCodec;
         tableCodec = CodecService.getDefault().createKeyValueCodec(
-            param.getTable().version, param.getTableDataSchema(), param.tableDataKeyMapping()
+            param.getIndexTable().version, param.getIndexTable().tupleType(), param.getIndexTable().keyMapping()
         );
         StoreInstance instance = Services.KV_STORE.getInstance(param.getTableId(), param.getPartId());
         List<VectorSearchResponse> searchResponseList = instance.vectorSearch(
@@ -136,7 +136,7 @@ public class TxnPartVectorOperator extends FilterProjectSourceOperator {
                 decode[decode.length - 1] = response.getDistance();
                 decode[vecIdx] = response.getFloatValues();
 
-                vecPriIdxMapping.forEach((key, value) -> decode[value] = vecTuples[key]);
+                //vecPriIdxMapping.forEach((key, value) -> decode[value] = vecTuples[key]);
                 results.add(decode);
             }
         } else {