From 403a877564353363e958cb542d099b37d58ae630 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao>
Date: Thu, 25 Apr 2024 08:52:29 +0800
Subject: [PATCH] set pk length

---
 source/libs/executor/src/scanoperator.c | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index ef92e566b6..838db4c571 100644
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -3211,7 +3211,7 @@ SOperatorInfo* createStreamScanOperatorInfo(SReadHandle* pHandle, STableScanPhys
   if (hasPrimaryKeyCol(pInfo)) {
     addPrimaryKeyCol(pInfo->pUpdateDataRes, pkType.type, pkType.bytes);
     pInfo->pkColType = pkType.type;
-    pInfo->pkColLen = pkType.bytes + 2;
+    pInfo->pkColLen = pkType.bytes;
   }
   pInfo->assignBlockUid = pTableScanNode->assignBlockUid;
   pInfo->partitionSup.needCalc = false;