xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix: rowSize check

This commit is contained in:
xsren 2024-10-23 11:38:46 +08:00
parent 2ae51f3118
commit 00d374358a
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/libs/executor/src/dataDispatcher.c
View File

@ -63,7 +63,7 @@ static int32_t inputSafetyCheck(SDataDispatchHandle* pHandle, const SInputData*
return TSDB_CODE_QRY_INVALID_INPUT; return TSDB_CODE_QRY_INVALID_INPUT;
} }
SDataBlockDescNode* pSchema = pHandle->pSchema; SDataBlockDescNode* pSchema = pHandle->pSchema;
if (pSchema == NULL || pSchema->outputRowSize > pInput->pData->info.rowSize) { if (pSchema == NULL || pSchema->totalRowSize != pInput->pData->info.rowSize) {
qError("invalid schema"); qError("invalid schema");
return TSDB_CODE_QRY_INVALID_INPUT; return TSDB_CODE_QRY_INVALID_INPUT;
} }
@ -77,6 +77,7 @@ static int32_t inputSafetyCheck(SDataDispatchHandle* pHandle, const SInputData*
realOutputRowSize += pSlotDesc->dataType.bytes; realOutputRowSize += pSlotDesc->dataType.bytes;
++numOfCols; ++numOfCols;
} else { } else {
// Slots must be sorted, and slots with 'output' set to true must come first
break; break;
} }
} }