From c6a71a4b66d6a7e41cc4fc17dff3d137a675e148 Mon Sep 17 00:00:00 2001 From: Hongze Cheng Date: Tue, 3 Jan 2023 18:29:30 +0800 Subject: [PATCH] more code --- source/dnode/vnode/src/tsdb/tsdbCompact.c | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/source/dnode/vnode/src/tsdb/tsdbCompact.c b/source/dnode/vnode/src/tsdb/tsdbCompact.c index 21caab8fee..bf61d0fbaf 100644 --- a/source/dnode/vnode/src/tsdb/tsdbCompact.c +++ b/source/dnode/vnode/src/tsdb/tsdbCompact.c @@ -867,6 +867,7 @@ static int32_t tsdbCompactFileSet(STsdbCompactor *pCompactor) { code = tBlockDataInit(&pCompactor->bData, (TABLEID *)pRowInfo, pTSchema, NULL, 0); TSDB_CHECK_CODE(code, lino, _exit); + pCompactor->tableId.suid = pRowInfo->suid; pCompactor->tableId.uid = pRowInfo->uid; } @@ -891,9 +892,10 @@ static int32_t tsdbCompactFileSet(STsdbCompactor *pCompactor) { // init block data if need if (init && (code = tBlockDataInit(&pCompactor->bData, (TABLEID *)pRowInfo, pTSchema, NULL, 0))) { TSDB_CHECK_CODE(code, lino, _exit); - pCompactor->tableId.suid = pRowInfo->suid; - pCompactor->tableId.uid = pRowInfo->uid; } + + pCompactor->tableId.suid = pRowInfo->suid; + pCompactor->tableId.uid = pRowInfo->uid; } // if append/merge the row causes nRow exceed maxRows @@ -903,8 +905,6 @@ static int32_t tsdbCompactFileSet(STsdbCompactor *pCompactor) { } // append/merge the row - pCompactor->tableId.suid = pRowInfo->suid; - pCompactor->tableId.uid = pRowInfo->uid; code = tBlockDataUpsertRow(&pCompactor->bData, &pRowInfo->row, pTSchema, pRowInfo->uid); TSDB_CHECK_CODE(code, lino, _exit);