From a706c4d49de81b696a757a33f73b935420565936 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao>
Date: Mon, 26 Aug 2024 14:58:12 +0800
Subject: [PATCH] fix(query): check error code for tsort

---
 source/libs/executor/src/scanoperator.c | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index 7a729b4611..7cad03db50 100644
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -5749,7 +5749,11 @@ SSDataBlock* getSortedTableMergeScanBlockData(SSortHandle* pHandle, SSDataBlock*
     while (1) {
       pTupleHandle = NULL;
       int32_t code = tsortNextTuple(pHandle, &pTupleHandle);
-      if (pTupleHandle == NULL || code != 0) {
+      if (code != TSDB_CODE_SUCCESS) {
+        qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(code));
+        T_LONG_JMP(pOperator->pTaskInfo->env, code);
+      }
+      if (pTupleHandle == NULL) {
         break;
       }