diff --git a/src/storage/memtable/mvcc/ob_mvcc_iterator.cpp b/src/storage/memtable/mvcc/ob_mvcc_iterator.cpp index 3fc6be7ca..a5eba8909 100644 --- a/src/storage/memtable/mvcc/ob_mvcc_iterator.cpp +++ b/src/storage/memtable/mvcc/ob_mvcc_iterator.cpp @@ -306,6 +306,8 @@ bool ObMvccValueIterator::read_by_sql_no( } else { can_read_by_sql_no = true; } + } else if (ctx.is_for_replay() && !iter->is_committed() && iter->get_ctx_descriptor() == ctx.get_ctx_descriptor()) { + can_read_by_sql_no = true; } if (can_read_by_sql_no) { if (query_flag.is_read_latest()) {