diff options
| author | snaury <snaury@ydb.tech> | 2022-12-15 17:46:13 +0300 |
|---|---|---|
| committer | snaury <snaury@ydb.tech> | 2022-12-15 17:46:13 +0300 |
| commit | e9c4938cd7149e5caf3c331d01d62a23f56a6d23 (patch) | |
| tree | fb83a56ded10363f4d43c5874808eb9d509c35d1 | |
| parent | 291141201be40c9f1a00ee0f21323b5ed45f61a3 (diff) | |
| download | ydb-e9c4938cd7149e5caf3c331d01d62a23f56a6d23.tar.gz | |
Fix a missing failure on locked writes in column shard
| -rw-r--r-- | ydb/core/tx/columnshard/columnshard__propose_transaction.cpp | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/ydb/core/tx/columnshard/columnshard__propose_transaction.cpp b/ydb/core/tx/columnshard/columnshard__propose_transaction.cpp index 2ec98a0b3c..102bae6c38 100644 --- a/ydb/core/tx/columnshard/columnshard__propose_transaction.cpp +++ b/ydb/core/tx/columnshard/columnshard__propose_transaction.cpp @@ -150,6 +150,8 @@ bool TTxProposeTransaction::Execute(TTransactionContext& txc, const TActorContex statusMessage = TStringBuilder() << "Commit TxId# " << txId << " references WriteId# " << writeId << " that is already locked by TxId# " << lw.PreparedTxId; + failed = true; + break; } } if (failed) { |