From c5b26b406f6e0eb493951734fee87805c2ef829f Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Mon, 19 Feb 2024 13:38:56 +0800 Subject: [PATCH] fix(stream): fix syntax error. --- source/libs/stream/src/streamExec.c | 1 + 1 file changed, 1 insertion(+) diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c index a2cf8bdab5..8d33eaae62 100644 --- a/source/libs/stream/src/streamExec.c +++ b/source/libs/stream/src/streamExec.c @@ -413,6 +413,7 @@ int32_t streamDoTransferStateToStreamTask(SStreamTask* pTask) { static int32_t haltCallback(SStreamTask* pTask, void* param) { streamTaskOpenAllUpstreamInput(pTask); streamTaskSendCheckpointReq(pTask); + return TSDB_CODE_SUCCESS; } int32_t streamTransferStateToStreamTask(SStreamTask* pTask) {