diff options
author | va-kuznecov <va-kuznecov@ydb.tech> | 2023-02-01 19:36:36 +0300 |
---|---|---|
committer | va-kuznecov <va-kuznecov@ydb.tech> | 2023-02-01 19:36:36 +0300 |
commit | d6f0689a827ab421a99aee1610eebc41b0cb4dab (patch) | |
tree | b19f7b4b40d9dd3d770181c9e32599adbd6212bf | |
parent | d9425c5f2c621a4ee71a9247ece350f811b0a7db (diff) | |
download | ydb-d6f0689a827ab421a99aee1610eebc41b0cb4dab.tar.gz |
Fix inf query duration in SessionActor
-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 7052e5cee73..8e087bace41 100644 --- a/ydb/core/kqp/session_actor/kqp_session_actor.cpp +++ b/ydb/core/kqp/session_actor/kqp_session_actor.cpp @@ -693,7 +693,6 @@ public: QueryState->TxCtx->OnBeginQuery(); - if (QueryState->NeedPersistentSnapshot()) { return AcquirePersistentSnapshot(); } else if (NeedSnapshot(*QueryState->TxCtx, *Config, /*rollback*/ false, QueryState->Commit, @@ -792,6 +791,7 @@ public: QueryState->TxCtx = MakeIntrusive<TKqpTransactionContext>(false, AppData()->FunctionRegistry, AppData()->TimeProvider, AppData()->RandomProvider); QueryState->QueryData = std::make_shared<TQueryData>(QueryState->TxCtx->TxAlloc); QueryState->TxCtx->SetIsolationLevel(settings); + QueryState->TxCtx->OnBeginQuery(); if (!Transactions.CreateNew(QueryState->TxId, QueryState->TxCtx)) { std::vector<TIssue> issues{ |