aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorva-kuznecov <va-kuznecov@ydb.tech>2023-02-01 19:36:36 +0300
committerva-kuznecov <va-kuznecov@ydb.tech>2023-02-01 19:36:36 +0300
commitd6f0689a827ab421a99aee1610eebc41b0cb4dab (patch)
treeb19f7b4b40d9dd3d770181c9e32599adbd6212bf
parentd9425c5f2c621a4ee71a9247ece350f811b0a7db (diff)
downloadydb-d6f0689a827ab421a99aee1610eebc41b0cb4dab.tar.gz
Fix inf query duration in SessionActor
-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 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{