set pk length

This commit is contained in:
54liuyao 2024-04-25 08:52:29 +08:00
parent 2a72ceadd1
commit 403a877564
1 changed files with 1 additions and 1 deletions

View File

@ -3211,7 +3211,7 @@ SOperatorInfo* createStreamScanOperatorInfo(SReadHandle* pHandle, STableScanPhys
if (hasPrimaryKeyCol(pInfo)) { if (hasPrimaryKeyCol(pInfo)) {
addPrimaryKeyCol(pInfo->pUpdateDataRes, pkType.type, pkType.bytes); addPrimaryKeyCol(pInfo->pUpdateDataRes, pkType.type, pkType.bytes);
pInfo->pkColType = pkType.type; pInfo->pkColType = pkType.type;
pInfo->pkColLen = pkType.bytes + 2; pInfo->pkColLen = pkType.bytes;
} }
pInfo->assignBlockUid = pTableScanNode->assignBlockUid; pInfo->assignBlockUid = pTableScanNode->assignBlockUid;
pInfo->partitionSup.needCalc = false; pInfo->partitionSup.needCalc = false;