From 56e5a483dd3d5dd98432dd2a43b13988cb260326 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Fri, 19 May 2023 20:00:32 +0800 Subject: [PATCH] other: update log. --- source/libs/stream/src/streamExec.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c index 2d950723bc..d77d6c21ce 100644 --- a/source/libs/stream/src/streamExec.c +++ b/source/libs/stream/src/streamExec.c @@ -124,7 +124,7 @@ static int32_t streamTaskExecImpl(SStreamTask* pTask, const void* data, SArray* assignOneDataBlock(&block, output); block.info.childId = pTask->selfChildId; - (*resSize) += blockDataGetSize(output); + (*resSize) += blockDataGetSize(output) + sizeof(SSDataBlock) + sizeof(SColumnInfoData) * blockDataGetNumOfCols(&block); taosArrayPush(pRes, &block); qDebug("s-task:%s (child %d) executed and get block, total blocks:%d, size:%.2fMiB", pTask->id.idStr, pTask->selfChildId, (int32_t)taosArrayGetSize(pRes),