diff --git a/source/dnode/vnode/src/tsdb/dev/tsdbCommit.c b/source/dnode/vnode/src/tsdb/dev/tsdbCommit.c index 6c9ad70e66a1393232a4c9d6b76eddd9ddec98ac..718e5024a1922868356e22a80db75fe6522462f9 100644 --- a/source/dnode/vnode/src/tsdb/dev/tsdbCommit.c +++ b/source/dnode/vnode/src/tsdb/dev/tsdbCommit.c @@ -602,6 +602,11 @@ static int32_t tsdbCommitFileSetEnd(SCommitter2 *committer) { int32_t code = 0; int32_t lino = 0; + if (committer->sttReader) { + code = tsdbSttFileReaderClose(&committer->sttReader); + TSDB_CHECK_CODE(code, lino, _exit); + } + if (committer->dataWriter) { code = tsdbDataFileWriterClose(&committer->dataWriter, 0, committer->fopArray); TSDB_CHECK_CODE(code, lino, _exit);