From 39ca9b537f0a68b6b447480e09a207ad34298782 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Fri, 21 Jul 2023 09:43:08 +0800 Subject: [PATCH] fix(stream): fix syntax error --- source/dnode/vnode/src/tq/tq.c | 1 + source/libs/stream/src/streamRecover.c | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c index 0d36933b9b..98e0696c19 100644 --- a/source/dnode/vnode/src/tq/tq.c +++ b/source/dnode/vnode/src/tq/tq.c @@ -814,6 +814,7 @@ int32_t tqExpandTask(STQ* pTq, SStreamTask* pTask, int64_t ver) { pTask->outputInfo.queue = streamQueueOpen(512 << 10); if (pTask->inputQueue == NULL || pTask->outputInfo.queue == NULL) { + tqError("s-task:%s failed to prepare the input/output queue, initialize task failed", pTask->id.idStr); return -1; } diff --git a/source/libs/stream/src/streamRecover.c b/source/libs/stream/src/streamRecover.c index 80b3c2a618..693d067506 100644 --- a/source/libs/stream/src/streamRecover.c +++ b/source/libs/stream/src/streamRecover.c @@ -26,7 +26,7 @@ static void streamTaskSetForReady(SStreamTask* pTask, int32_t numOfReqs) { int64_t el = (taosGetTimestampMs() - pTask->initTs); qDebug("s-task:%s all %d downstream ready, init completed, elapsed time:%dms, task status:%s", - pTask->id.idStr, numOfReqs, el, streamGetTaskStatusStr(pTask->status.taskStatus)); + pTask->id.idStr, numOfReqs, (int32_t) el, streamGetTaskStatusStr(pTask->status.taskStatus)); } int32_t streamStartRecoverTask(SStreamTask* pTask, int8_t igUntreated) {