Skip to content

Commit

Permalink
delete extra
Browse files Browse the repository at this point in the history
  • Loading branch information
VPolka committed Apr 24, 2024
1 parent 35d12fa commit 1e0bec3
Showing 1 changed file with 1 addition and 10 deletions.
11 changes: 1 addition & 10 deletions ydb/core/kqp/session_actor/kqp_session_actor.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -575,13 +575,6 @@ class TKqpSessionActor : public TActorBootstrapped<TKqpSessionActor> {
}

void OnSuccessCompileRequest() {
if (QueryState->HasTxControl()) {
const auto& txControl = QueryState->GetTxControl();
if (txControl.tx_selector_case() == Ydb::Table::TransactionControl::kTxId) {
LOG_E("TTTTTXXXXXX IIIIIDDDDD " << txControl.tx_id());
}
}

if (QueryState->GetAction() == NKikimrKqp::QUERY_ACTION_PREPARE ||
QueryState->GetAction() == NKikimrKqp::QUERY_ACTION_EXPLAIN)
{
Expand Down Expand Up @@ -2067,9 +2060,7 @@ class TKqpSessionActor : public TActorBootstrapped<TKqpSessionActor> {
} else {
CleanupCtx.reset();
bool doNotKeepSession = QueryState && !QueryState->KeepSession;
//if (!QueryState || QueryState->ProcessingLastStatement()) {
QueryState.reset();
//}
QueryState.reset();
if (doNotKeepSession) {
// TEvCloseSessionRequest was received in final=false CleanupState, so actor should rerun Cleanup with final=true
CleanupAndPassAway();
Expand Down

0 comments on commit 1e0bec3

Please sign in to comment.