From c1a4e63515302d1b048d3374cf6a9408b9f3c917 Mon Sep 17 00:00:00 2001
From: guoxu <13910754971@163.com>
Date: Thu, 26 Dec 2024 15:53:03 +0800
Subject: [PATCH] [feat][executor] Change schemas for fixing the wrong column
 index when decode vector value buf.

---
 .../java/io/dingodb/exec/operator/TxnPartVectorOperator.java  | 4 ++--
 1 file changed, 2 insertions(+), 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
index 589ae1c2e5..d74fddfc80 100644
--- 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 {