From 0f4da0ef5720dd048df9f36652f7bdbe091b56e7 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Tue, 26 Apr 2022 17:34:00 +0800 Subject: [PATCH] fix(query): copy the hasNull attribute to destination SColumnInfoData. --- source/common/src/tdatablock.c | 2 ++ source/libs/executor/src/groupoperator.c | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/source/common/src/tdatablock.c b/source/common/src/tdatablock.c index 5270bdeb46..d6a6ba5b13 100644 --- a/source/common/src/tdatablock.c +++ b/source/common/src/tdatablock.c @@ -311,6 +311,8 @@ int32_t colDataAssign(SColumnInfoData* pColumnInfoData, const SColumnInfoData* p memcpy(pColumnInfoData->pData, pSource->pData, pSource->info.bytes * numOfRows); } + pColumnInfoData->hasNull = pSource->hasNull; + pColumnInfoData->info = pSource->info; return 0; } diff --git a/source/libs/executor/src/groupoperator.c b/source/libs/executor/src/groupoperator.c index 52bdbea8a5..27c616498e 100644 --- a/source/libs/executor/src/groupoperator.c +++ b/source/libs/executor/src/groupoperator.c @@ -220,7 +220,7 @@ static void doHashGroupbyAgg(SOperatorInfo* pOperator, SSDataBlock* pBlock) { } // The first row of a new block does not belongs to the previous existed group - if (!equal && j == 0) { + if (j == 0) { num++; recordNewGroupKeys(pInfo->pGroupCols, pInfo->pGroupColVals, pBlock, j, numOfGroupCols); continue;