diff --git a/src/storage/access/ob_single_merge.cpp b/src/storage/access/ob_single_merge.cpp index b0fce131b..11477b170 100644 --- a/src/storage/access/ob_single_merge.cpp +++ b/src/storage/access/ob_single_merge.cpp @@ -253,6 +253,7 @@ int ObSingleMerge::inner_get_next_row(ObDatumRow &row) access_ctx_->query_flag_.set_not_use_row_cache(); nop_pos_.reset(); full_row_.count_ = 0; + full_row_.row_flag_.reset(); full_row_.row_flag_.set_flag(ObDmlFlag::DF_NOT_EXIST); full_row_.snapshot_version_ = 0L; access_ctx_->use_fuse_row_cache_ = enable_fuse_row_cache; diff --git a/src/storage/access/ob_sstable_multi_version_row_iterator.cpp b/src/storage/access/ob_sstable_multi_version_row_iterator.cpp index feef868d3..f9f322adc 100644 --- a/src/storage/access/ob_sstable_multi_version_row_iterator.cpp +++ b/src/storage/access/ob_sstable_multi_version_row_iterator.cpp @@ -81,6 +81,7 @@ int ObSSTableMultiVersionRowGetter::inner_open( } else if (OB_FAIL(not_exist_row_.init(*access_ctx.get_range_allocator(), iter_param.get_out_col_cnt()))) { LOG_WARN("fail to init datum row", K(ret)); } else { + not_exist_row_.row_flag_.reset(); not_exist_row_.row_flag_.set_flag(ObDmlFlag::DF_NOT_EXIST); } } @@ -205,6 +206,7 @@ int ObSSTableMultiVersionRowMultiGetter::inner_open( } else if (OB_FAIL(not_exist_row_.init(*access_ctx.get_range_allocator(), iter_param.get_out_col_cnt()))) { LOG_WARN("fail to init datum row", K(ret)); } else { + not_exist_row_.row_flag_.reset(); not_exist_row_.row_flag_.set_flag(ObDmlFlag::DF_NOT_EXIST); } } diff --git a/src/storage/blocksstable/ob_micro_block_row_getter.cpp b/src/storage/blocksstable/ob_micro_block_row_getter.cpp index 0def26a73..772da2a98 100644 --- a/src/storage/blocksstable/ob_micro_block_row_getter.cpp +++ b/src/storage/blocksstable/ob_micro_block_row_getter.cpp @@ -410,6 +410,7 @@ int ObMicroBlockRowGetter::get_not_exist_row(const ObDatumRowkey &rowkey, const LOG_WARN("fail to reserve datum row", K(ret), KPC(read_info)); } else { row_.count_ = rowkey.get_datum_cnt(); + row_.row_flag_.reset(); row_.row_flag_.set_flag(ObDmlFlag::DF_NOT_EXIST); //TODO maybe we do not need to copy the rowkey datum for (int64_t i = 0; i < rowkey.get_datum_cnt(); i++) {