diff --git a/source/dnode/vnode/src/tsdb/tsdbCommit2.c b/source/dnode/vnode/src/tsdb/tsdbCommit2.c
index db7abf443c111ac2efba988efb442733c0f5b81f..e316a79d92e6e293bfbe5eb80231cb5e148d3485 100644
--- a/source/dnode/vnode/src/tsdb/tsdbCommit2.c
+++ b/source/dnode/vnode/src/tsdb/tsdbCommit2.c
@@ -122,6 +122,14 @@ static int32_t tsdbCommitTSData(SCommitter2 *committer) {
       committer->ctx->tbid->uid = row->uid;
     }
 
+    int64_t ts = TSDBROW_TS(&row->row);
+    if (ts > committer->ctx->maxKey) {
+      committer->ctx->nextKey = TMIN(committer->ctx->nextKey, ts);
+      code = tsdbIterMergerSkipTableData(committer->dataIterMerger, (TABLEID *)row);
+      TSDB_CHECK_CODE(code, lino, _exit);
+      continue;
+    }
+
     code = tsdbFSetWriteRow(committer->writer, row);
     TSDB_CHECK_CODE(code, lino, _exit);