From 8a6a876f6782b4555dced9fb69b3cf4c993f4ee5 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Mon, 10 Jul 2023 22:53:15 +0800 Subject: [PATCH] fix(stream): fix error in generating checkpoint. --- source/libs/stream/src/streamExec.c | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c index 7044eb3b2a..b3e5dc2475 100644 --- a/source/libs/stream/src/streamExec.c +++ b/source/libs/stream/src/streamExec.c @@ -527,11 +527,12 @@ int32_t streamTryExec(SStreamTask* pTask) { qDebug("vgId:%d do vnode wide checkpoint completed, checkpoint id:%"PRId64, pMeta->vgId); } - code = updateCheckPointInfo(pTask, pTask->checkpointingId); - if (code != TSDB_CODE_SUCCESS) { - return code; + if (pTask->info.taskLevel != TASK_LEVEL__SINK) { + code = updateCheckPointInfo(pTask, pTask->checkpointingId); + if (code != TSDB_CODE_SUCCESS) { + return code; + } } - // send check point response to upstream task if (pTask->info.taskLevel == TASK_LEVEL__SOURCE) { code = streamTaskSendCheckpointSourceRsp(pTask);