fix(stream): fix syntax error.

2024-02-19 13:38:14 +08:00 · 2024-02-19 13:38:14 +08:00 · 730edf24f9
parent d3e8adf2eb
commit 730edf24f9
1 changed files with 1 additions and 0 deletions
--- a/source/libs/stream/src/streamTask.c
+++ b/source/libs/stream/src/streamTask.c
@ -860,6 +860,7 @@ static int32_t taskPauseCallback(SStreamTask* pTask, void* param) {
  }

  stDebug("vgId:%d s-task:%s set pause flag and pause task", pMeta->vgId, pTask->id.idStr);
+  return TSDB_CODE_SUCCESS;
 }

 void streamTaskPause(SStreamMeta* pMeta, SStreamTask* pTask) {