diff --git a/source/libs/executor/src/sortoperator.c b/source/libs/executor/src/sortoperator.c
index 5cac3f5f86..95c06865f0 100644
--- a/source/libs/executor/src/sortoperator.c
+++ b/source/libs/executor/src/sortoperator.c
@@ -279,6 +279,9 @@ static int32_t getSortedBlockData(SSortHandle* pHandle, SSDataBlock* pDataBlock,
     }
 
     TSDB_CHECK_CODE(code, lino, _error);
+    if (pTupleHandle == NULL) {
+      break;
+    }
 
     code = appendOneRowToDataBlock(p, pTupleHandle);
     QUERY_CHECK_CODE(code, lino, _error);