fix(stream): fix an syntax error.

c9f3e0b0 · Haojun Liao · fe5e48b8 · c9f3e0b0
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

source/libs/stream/src/streamRecover.c source/libs/stream/src/streamRecover.c +1 -1

未找到文件。
--- a/source/libs/stream/src/streamRecover.c
+++ b/source/libs/stream/src/streamRecover.c
@@ -209,7 +209,7 @@ int32_t streamTaskCheckStatus(SStreamTask* pTask, int32_t upstreamTaskId, int32_

  if (pInfo->stage < stage) {
    qError("s-task:%s receive msg from upstream task:0x%x(vgId:%d), new stage received:%" PRId64 ", prev:%" PRId64,
-           pTask->id.idStr, vgId, stage, pInfo->stage);
+           pTask->id.idStr, upstreamTaskId, vgId, stage, pInfo->stage);
  }

  return ((pTask->status.downstreamReady == 1) && (pInfo->stage == upstreamTaskId))? 1:0;