diff --git a/src/storage/ob_single_merge.cpp b/src/storage/ob_single_merge.cpp index 3a82f8c588cd4efe5e9ead8fd20325a4c0ac7777..8d624906aec767c97e0cb9a26f115c3dd6479520 100644 --- a/src/storage/ob_single_merge.cpp +++ b/src/storage/ob_single_merge.cpp @@ -189,9 +189,8 @@ int ObSingleMerge::inner_get_next_row(ObStoreRow& row) if (OB_FAIL(tables.at(i, table))) { STORAGE_LOG(WARN, "fail to get ith table", K(ret)); } else { - if (table->get_base_version() < row_cache_snapshot_version && - row_cache_snapshot_version <= table->get_upper_trans_version() && - (!table->is_multi_version_minor_sstable() || sstable_end_log_ts <= table->get_end_log_ts())) { + if (table->get_base_version() < row_cache_snapshot_version + && row_cache_snapshot_version <= table->get_upper_trans_version()) { if (table->get_multi_version_start() >= row_cache_snapshot_version) { // do not use fuse row cache handle_.reset();