fix(query): fix bugs caused by refactor.

This commit is contained in:
Haojun Liao 2024-05-19 00:16:43 +08:00
parent 8f4da7f308
commit 19b17826d4
1 changed files with 4 additions and 1 deletions

View File

@ -365,7 +365,10 @@ int32_t qwGetQueryResFromSink(QW_FPARAMS_DEF, SQWTaskCtx *ctx, int32_t *dataLen,
pOutput->precision = output.precision;
pOutput->bufStatus = output.bufStatus;
pOutput->useconds = output.useconds;
pOutput->compressed = output.compressed;
if (output.compressed) {
pOutput->compressed = output.compressed;
}
pOutput->numOfCols = output.numOfCols;
pOutput->numOfRows += output.numOfRows;
pOutput->numOfBlocks++;