diff --git a/source/libs/executor/src/sortoperator.c b/source/libs/executor/src/sortoperator.c index c495e59d94..1c241dffec 100644 --- a/source/libs/executor/src/sortoperator.c +++ b/source/libs/executor/src/sortoperator.c @@ -213,8 +213,10 @@ static int32_t nextTupleWithGroupId(SSortHandle* pHandle, SSortOperatorInfo* pIn STupleHandle* retTuple = pInfo->pGroupIdCalc->pSavedTuple; if (!retTuple) { code = tsortNextTuple(pHandle, &retTuple); - qError("failed to get next tuple, code:%s", tstrerror(code)); - return code; + if (code) { + qError("failed to get next tuple, code:%s", tstrerror(code)); + return code; + } } if (retTuple) {