diff --git a/ydb/core/kqp/session_actor/kqp_session_actor.cpp b/ydb/core/kqp/session_actor/kqp_session_actor.cpp index 54f8ab9e7013..63caf5580957 100644 --- a/ydb/core/kqp/session_actor/kqp_session_actor.cpp +++ b/ydb/core/kqp/session_actor/kqp_session_actor.cpp @@ -192,10 +192,6 @@ class TKqpSessionActor : public TActorBootstrapped { RequestCounters->TxProxyMon = MakeIntrusive(AppData()->Counters); CompilationCookie = std::make_shared>(true); - FillSettings.AllResultsBytesLimit = Nothing(); - FillSettings.RowsLimitPerWrite = Config->_ResultRowsLimit.Get(); - FillSettings.Format = IDataProvider::EResultFormat::Custom; - FillSettings.FormatDetails = TString(KikimrMkqlProtoFormat); FillGUCSettings(); auto optSessionId = TryDecodeYdbSessionId(SessionId); @@ -1806,7 +1802,7 @@ class TKqpSessionActor : public TActorBootstrapped { continue; } - TMaybe effectiveRowsLimit = FillSettings.RowsLimitPerWrite; + TMaybe effectiveRowsLimit = {}; if (QueryState->PreparedQuery->GetResults(i).GetRowsLimit()) { effectiveRowsLimit = QueryState->PreparedQuery->GetResults(i).GetRowsLimit(); } @@ -2564,7 +2560,6 @@ class TKqpSessionActor : public TActorBootstrapped { std::unique_ptr CleanupCtx; ui32 QueryId = 0; TKikimrConfiguration::TPtr Config; - IDataProvider::TFillSettings FillSettings; TTransactionsCache Transactions; std::unique_ptr QueryResponse; std::optional ShutdownState;