fix: fix empty downstream input for group sort operator

cbacd1fd · shenglian zhou · faf5424b · cbacd1fd
显示空白变更内容
内联并排

Showing with 4 addition and 0 deletion

source/libs/executor/src/sortoperator.c source/libs/executor/src/sortoperator.c +4 -0

未找到文件。
--- a/source/libs/executor/src/sortoperator.c
+++ b/source/libs/executor/src/sortoperator.c
@@ -387,6 +387,10 @@ SSDataBlock* doGroupSort(SOperatorInfo* pOperator) {
    pInfo->hasGroupId = true;

    pInfo->prefetchedSortInput = pOperator->pDownstream[0]->fpSet.getNextFn(pOperator->pDownstream[0]);
+    if (pInfo->prefetchedSortInput == NULL) {
+      doSetOperatorCompleted(pOperator);
+      return NULL;
+    }
    pInfo->currGroupId = pInfo->prefetchedSortInput->info.groupId;
    pInfo->childOpStatus = CHILD_OP_NEW_GROUP;
    beginSortGroup(pOperator);