Merge pull request #19094 from taosdata/feature/stream_3.0

refactor: add debug log
taosdata · Dec 23, 2022 · 8cf7375 · 8cf7375
2 parents 13dfaae + 69d4105
commit 8cf7375
Showing 1 changed file with 6 additions and 1 deletion.
diff --git 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;