aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorva-kuznecov <va-kuznecov@ydb.tech>2023-08-25 20:58:52 +0300
committerva-kuznecov <va-kuznecov@ydb.tech>2023-08-25 21:24:31 +0300
commitbbb47b7f6b8dd9fd3385f5a58e8825bb9ac202d0 (patch)
tree8a4fbe1efe522dd1e01fc019f1ac55b44b65732d
parentb3f82c6ee5adfd3ea07e279fc46581811a22e21c (diff)
downloadydb-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.cpp2
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);