fix(stream): return value.

2024-09-29 22:59:18 +08:00 · 2024-09-29 22:59:18 +08:00 · 4173144ded
parent 1e96ea4b54
commit 4173144ded
1 changed files with 4 additions and 2 deletions
--- a/source/libs/executor/src/sortoperator.c
+++ b/source/libs/executor/src/sortoperator.c
@ -213,9 +213,11 @@ static int32_t nextTupleWithGroupId(SSortHandle* pHandle, SSortOperatorInfo* pIn
  STupleHandle* retTuple = pInfo->pGroupIdCalc->pSavedTuple;
  if (!retTuple) {
    code = tsortNextTuple(pHandle, &retTuple);
+    if (code) {
      qError("failed to get next tuple, code:%s", tstrerror(code));
      return code;
    }
+  }

  if (retTuple) {
    int32_t newGroup;