From 5d4efe11980f6a954b9752144803c94ff2aa5ad0 Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Mon, 3 Jul 2023 11:46:05 +0800
Subject: [PATCH] fix(stream): fix error in pause.

---
 source/libs/stream/src/streamExec.c | 1 +
 1 file changed, 1 insertion(+)

diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c
index bf6fcaced7..9fddcf9155 100644
--- a/source/libs/stream/src/streamExec.c
+++ b/source/libs/stream/src/streamExec.c
@@ -335,6 +335,7 @@ int32_t streamExecForAll(SStreamTask* pTask) {
 
     while (1) {
       if (streamTaskShouldPause(&pTask->status)) {
+        qDebug("s-task:%s task should pause, input blocks:%s", pTask->id.idStr, batchSize);
         if (batchSize > 1) {
           break;
         } else {