diff --git a/src/storage/ddl/ob_direct_load_struct.cpp b/src/storage/ddl/ob_direct_load_struct.cpp
index 66948699b9..f49df521df 100644
--- a/src/storage/ddl/ob_direct_load_struct.cpp
+++ b/src/storage/ddl/ob_direct_load_struct.cpp
@@ -406,6 +406,8 @@ int ObLobMetaRowIterator::get_next_row(const blocksstable::ObDatumRow *&row)
       tmp_row_.storage_datums_[ObLobMetaUtil::SEQ_ID_COL_ID + 2].set_int(-get_seq_no());
       tmp_row_.set_trans_id(trans_id_);
       tmp_row_.row_flag_.set_flag(ObDmlFlag::DF_INSERT);
+      tmp_row_.mvcc_row_flag_.set_compacted_multi_version_row(true);
+      tmp_row_.mvcc_row_flag_.set_first_multi_version_row(true);
       tmp_row_.mvcc_row_flag_.set_last_multi_version_row(true);
       tmp_row_.mvcc_row_flag_.set_uncommitted_row(trans_id_.is_valid());
       row = &tmp_row_;
diff --git a/src/storage/direct_load/ob_direct_load_insert_table_ctx.cpp b/src/storage/direct_load/ob_direct_load_insert_table_ctx.cpp
index 23eadd0647..694d2e7334 100644
--- a/src/storage/direct_load/ob_direct_load_insert_table_ctx.cpp
+++ b/src/storage/direct_load/ob_direct_load_insert_table_ctx.cpp
@@ -358,6 +358,8 @@ int ObDirectLoadInsertTabletContext::init_datum_row(ObDatumRow &datum_row)
         !param_->is_incremental_ ? param_->snapshot_version_ : INT64_MAX;
       datum_row.trans_id_ = param_->trans_param_.tx_id_;
       datum_row.row_flag_.set_flag(ObDmlFlag::DF_INSERT, !param_->is_incremental_ ? DF_TYPE_NORMAL : DF_TYPE_INSERT_DELETE);
+      datum_row.mvcc_row_flag_.set_compacted_multi_version_row(true);
+      datum_row.mvcc_row_flag_.set_first_multi_version_row(true);
       datum_row.mvcc_row_flag_.set_last_multi_version_row(true);
       datum_row.mvcc_row_flag_.set_uncommitted_row(param_->is_incremental_);
       // fill trans_version
@@ -387,6 +389,8 @@ int ObDirectLoadInsertTabletContext::init_lob_datum_row(blocksstable::ObDatumRow
         !param_->is_incremental_ ? param_->snapshot_version_ : INT64_MAX;
       datum_row.trans_id_ = param_->trans_param_.tx_id_;
       datum_row.row_flag_.set_flag(is_delete ? ObDmlFlag::DF_DELETE : ObDmlFlag::DF_INSERT);
+      datum_row.mvcc_row_flag_.set_compacted_multi_version_row(true);
+      datum_row.mvcc_row_flag_.set_first_multi_version_row(true);
       datum_row.mvcc_row_flag_.set_last_multi_version_row(true);
       datum_row.mvcc_row_flag_.set_uncommitted_row(param_->is_incremental_);
       // fill trans_version