diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c
index cf6cab240150813d07cb4f44d3a580068c35dfcd..9495dcd69ca4252759b156c7bee305f1f57567c8 100644
--- a/source/libs/stream/src/streamExec.c
+++ b/source/libs/stream/src/streamExec.c
@@ -210,10 +210,8 @@ int32_t streamScanExec(SStreamTask* pTask, int32_t batchSize) {
       block.info.childId = pTask->info.selfChildId;
       taosArrayPush(pRes, &block);
 
-      numOfBlocks++;
-      if (numOfBlocks >= batchSize || code != TSDB_CODE_SUCCESS) {
-        qDebug("s-task:%s scan exec numOfBlocks:%d, limit:%d, code:%s", pTask->id.idStr, numOfBlocks, batchSize,
-               tstrerror(code));
+      if ((++numOfBlocks) >= batchSize) {
+        qDebug("s-task:%s scan exec numOfBlocks:%d, output limit:%d reached", pTask->id.idStr, numOfBlocks, batchSize);
         break;
       }
     }