diff options
author | va-kuznecov <va-kuznecov@ydb.tech> | 2023-08-25 20:58:52 +0300 |
---|---|---|
committer | va-kuznecov <va-kuznecov@ydb.tech> | 2023-08-25 21:24:31 +0300 |
commit | bbb47b7f6b8dd9fd3385f5a58e8825bb9ac202d0 (patch) | |
tree | 8a4fbe1efe522dd1e01fc019f1ac55b44b65732d | |
parent | b3f82c6ee5adfd3ea07e279fc46581811a22e21c (diff) | |
download | ydb-bbb47b7f6b8dd9fd3385f5a58e8825bb9ac202d0.tar.gz |
Force tx commit in case of QUERY_ACTION_COMMIT_TX KIKIMR-19107
-rw-r--r-- | ydb/core/kqp/session_actor/kqp_session_actor.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/core/kqp/session_actor/kqp_session_actor.cpp b/ydb/core/kqp/session_actor/kqp_session_actor.cpp index 4a4c0092aa..70336809bf 100644 --- a/ydb/core/kqp/session_actor/kqp_session_actor.cpp +++ b/ydb/core/kqp/session_actor/kqp_session_actor.cpp @@ -272,7 +272,7 @@ public: YQL_ENSURE(txControl.tx_selector_case() == Ydb::Table::TransactionControl::kTxId, "Can't commit transaction - " << " there is no TxId in Query's TxControl"); - QueryState->Commit = txControl.commit_tx(); + QueryState->Commit = true; auto txId = TTxId::FromString(txControl.tx_id()); auto txCtx = Transactions.Find(txId); |