diff --git a/source/dnode/vnode/src/tsdb/tsdbCommit.c b/source/dnode/vnode/src/tsdb/tsdbCommit.c index 674e29616c9937f09558fad00aac44638cf9866e..df6ff7caa43bdbde437d2bbb6d6b547ce1c3a54b 100644 --- a/source/dnode/vnode/src/tsdb/tsdbCommit.c +++ b/source/dnode/vnode/src/tsdb/tsdbCommit.c @@ -376,7 +376,7 @@ static int32_t tsdbCommitMemoryData(SCommitter *pCommitter, SBlockIdx *pBlockIdx block.last = 0; } - code = tsdbWriteBlockData(pCommitter->pWriter, &pCommitter->bDataN, NULL, pBlockIdx, &block); + code = tsdbWriteBlockData(pCommitter->pWriter, &pCommitter->bDataN, NULL, NULL, pBlockIdx, &block); if (code) goto _err; code = tMapDataPutItem(&pCommitter->nBlock, &block, tPutBlock); @@ -454,7 +454,7 @@ static int32_t tsdbMergeCommitImpl(SCommitter *pCommitter, SBlockIdx *pBlockIdx, _write_block_data: block.last = pCommitter->bDataN.nRow < pCommitter->minRow ? 1 : 0; - code = tsdbWriteBlockData(pCommitter->pWriter, &pCommitter->bDataN, NULL, pBlockIdx, &block); + code = tsdbWriteBlockData(pCommitter->pWriter, &pCommitter->bDataN, NULL, NULL, pBlockIdx, &block); if (code) goto _err; code = tMapDataPutItem(&pCommitter->nBlock, &block, tPutBlock);