diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c index e4a931641622501ccf57a3345fcd02f3a90738d6..03d19d760ad7a2f8a5ab04c6ca6b0ab96bb645ae 100644 --- a/src/query/src/qExecutor.c +++ b/src/query/src/qExecutor.c @@ -1713,9 +1713,6 @@ static void doHashGroupbyAgg(SOperatorInfo* pOperator, SGroupbyOperatorInfo *pIn int32_t num = 0; for (int32_t j = 0; j < pSDataBlock->info.rows; ++j) { char* val = ((char*)pColInfoData->pData) + bytes * j; - if (isNull(val, type)) { - continue; - } // Compare with the previous row of this column, and do not set the output buffer again if they are identical. if (pInfo->prevData == NULL) {