fix(stream): fix error in pause.

5d4efe11 · Haojun Liao · 317a7c83 · 5d4efe11
隐藏空白更改
内联并排

Showing with 1 addition and 0 deletion

source/libs/stream/src/streamExec.c source/libs/stream/src/streamExec.c +1 -0

未找到文件。
--- 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 {