diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c index c58da7d3f9..048bebcc5a 100644 --- a/source/libs/stream/src/streamExec.c +++ b/source/libs/stream/src/streamExec.c @@ -622,6 +622,8 @@ int32_t streamExecForAll(SStreamTask* pTask) { if (type == STREAM_INPUT__CHECKPOINT) { ASSERT(pTask->status.taskStatus == TASK_STATUS__CK); pTask->status.taskStatus = TASK_STATUS__CK_READY; + qDebug("s-task:%s checkpoint block received, set the status:%s", pTask->id.idStr, + streamGetTaskStatusStr(pTask->status.taskStatus)); return 0; } }