From 15573efbbc57a27c7a8c980a3cf5fa8fea5cfe5b Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Thu, 11 Jul 2024 14:57:40 +0800 Subject: [PATCH] fix(stream):commit the update of table meta. --- source/libs/stream/src/streamCheckpoint.c | 3 +++ 1 file changed, 3 insertions(+) diff --git a/source/libs/stream/src/streamCheckpoint.c b/source/libs/stream/src/streamCheckpoint.c index cdb5bf0b50..e555db82f6 100644 --- a/source/libs/stream/src/streamCheckpoint.c +++ b/source/libs/stream/src/streamCheckpoint.c @@ -442,6 +442,9 @@ int32_t streamTaskUpdateTaskCheckpointInfo(SStreamTask* pTask, bool restored, SV id, vgId, pReq->taskId, numOfTasks); } streamMetaWLock(pMeta); + if (streamMetaCommit(pMeta) < 0) { + // persist to disk + } } return TSDB_CODE_SUCCESS;