From 69d410591f7600670c5bffec1c231b2039b37e88 Mon Sep 17 00:00:00 2001
From: Liu Jicong <liujicong@qq.com>
Date: Thu, 22 Dec 2022 17:14:17 +0800
Subject: [PATCH] refactor: add debug log

---
 source/libs/stream/src/streamExec.c | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c
index 20608a6cf3..b5bceb9b94 100644
--- a/source/libs/stream/src/streamExec.c
+++ b/source/libs/stream/src/streamExec.c
@@ -121,7 +121,11 @@ int32_t streamScanExec(SStreamTask* pTask, int32_t batchSz) {
       block.info.childId = pTask->selfChildId;
       taosArrayPush(pRes, &block);
 
-      if (++batchCnt >= batchSz) break;
+      batchCnt++;
+
+      qDebug("task %d scan exec block num %d, block limit %d", pTask->taskId, batchCnt, batchSz);
+
+      if (batchCnt >= batchSz) break;
     }
     if (taosArrayGetSize(pRes) == 0) {
       taosArrayDestroy(pRes);
@@ -139,6 +143,7 @@ int32_t streamScanExec(SStreamTask* pTask, int32_t batchSz) {
     streamTaskOutput(pTask, qRes);
 
     if (pTask->outputType == TASK_OUTPUT__FIXED_DISPATCH || pTask->outputType == TASK_OUTPUT__SHUFFLE_DISPATCH) {
+      qDebug("task %d scan exec dispatch block num %d", pTask->taskId, batchCnt);
       streamDispatch(pTask);
     }
     if (finished) break;
-- 
GitLab