From 2a859b4e79e0e95abc5e92a07fb72a0ac2ba2fc7 Mon Sep 17 00:00:00 2001 From: Handora Date: Wed, 10 Jan 2024 03:22:40 +0000 Subject: [PATCH] [BUG] add seq no reverse check into the same sql check --- src/storage/memtable/ob_concurrent_control.cpp | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/storage/memtable/ob_concurrent_control.cpp b/src/storage/memtable/ob_concurrent_control.cpp index 56f5434052..9311bfed68 100644 --- a/src/storage/memtable/ob_concurrent_control.cpp +++ b/src/storage/memtable/ob_concurrent_control.cpp @@ -150,7 +150,9 @@ int check_sequence_set_violation(const concurrent_control::ObWriteFlag write_fla K(writer_tx_id), K(writer_dml_flag), K(writer_seq_no), K(locker_tx_id), K(locker_dml_flag), K(locker_seq_no)); } - } else if (writer_seq_no < locker_seq_no) { + } + + if (OB_SUCC(ret) && writer_seq_no < locker_seq_no) { // We need guarantee the right sequence of the same txn operations ret = OB_ERR_UNEXPECTED; TRANS_LOG(ERROR, "wrong row of sequence on one row found", K(reader_seq_no),