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) {