From 46529d383c4ea6783ff2a839dc3d1543ede706a0 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Sun, 27 Aug 2023 00:18:41 +0800 Subject: [PATCH] fix(stream): build checkpoint for sink tasks. --- source/libs/stream/src/streamCheckpoint.c | 1 + 1 file changed, 1 insertion(+) diff --git a/source/libs/stream/src/streamCheckpoint.c b/source/libs/stream/src/streamCheckpoint.c index 69f35d8c07..b40d0a1804 100644 --- a/source/libs/stream/src/streamCheckpoint.c +++ b/source/libs/stream/src/streamCheckpoint.c @@ -219,6 +219,7 @@ int32_t streamProcessCheckpointBlock(SStreamTask* pTask, SStreamDataBlock* pBloc qDebug("s-task:%s process checkpoint block, all %d upstreams sent checkpoint msgs, send ready msg to upstream", id, num); streamFreeQitem((SStreamQueueItem*)pBlock); + streamTaskBuildCheckpoint(pTask); } else { qDebug( "s-task:%s process checkpoint block, all %d upstreams sent checkpoint msgs, dispatch checkpoint msg "