fix partition by column

This commit is contained in:
Ganlin Zhao 2022-11-29 18:00:44 +08:00
parent daeeacb450
commit 8c3ff15342
1 changed files with 2 additions and 1 deletions

View File

@ -1507,7 +1507,8 @@ static int32_t doOpenAggregateOptr(SOperatorInfo* pOperator) {
while (1) {
SSDataBlock* pBlock = downstream->fpSet.getNextFn(downstream);
if (pBlock == NULL) {
if (!hasValidBlock) {
if (!hasValidBlock &&
downstream->operatorType != QUERY_NODE_PHYSICAL_PLAN_PARTITION) {
createDataBlockForEmptyInput(pOperator, &pBlock);
if (pBlock == NULL) {
break;