Skip to content

Commit 5955bb8

Browse files
committed
Fixed build
1 parent a3b0e61 commit 5955bb8

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

ydb/core/kqp/executer_actor/kqp_executer_impl.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1265,7 +1265,7 @@ class TKqpExecuterBase : public TActor<TDerived> {
12651265

12661266
bool RestoreTasksGraph() {
12671267
if (Request.QueryPhysicalGraph) {
1268-
TasksGraph.RestoreTasksGraphInfo(ResourcesSnapshot, *Request.QueryPhysicalGraph);
1268+
TasksGraph.RestoreTasksGraphInfo(Request.Transactions, ResourcesSnapshot, *Request.QueryPhysicalGraph);
12691269
}
12701270

12711271
return TasksGraph.GetMeta().IsRestored;

ydb/core/kqp/executer_actor/kqp_tasks_graph.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1557,7 +1557,7 @@ void TKqpTasksGraph::PersistTasksGraphInfo(NKikimrKqp::TQueryPhysicalGraph& resu
15571557
}
15581558
}
15591559

1560-
void TKqpTasksGraph::RestoreTasksGraphInfo(const TVector<NKikimrKqp::TKqpNodeResources>& resourcesSnapshot, const NKikimrKqp::TQueryPhysicalGraph& graphInfo) {
1560+
void TKqpTasksGraph::RestoreTasksGraphInfo(const TVector<IKqpGateway::TPhysicalTxData>& transactions, const TVector<NKikimrKqp::TKqpNodeResources>& resourcesSnapshot, const NKikimrKqp::TQueryPhysicalGraph& graphInfo) {
15611561
GetMeta().IsRestored = true;
15621562
GetMeta().AllowWithSpilling = false;
15631563

@@ -1743,8 +1743,8 @@ void TKqpTasksGraph::RestoreTasksGraphInfo(const TVector<NKikimrKqp::TKqpNodeRes
17431743
YQL_ENSURE(id == newChannel.Id);
17441744
}
17451745

1746-
for (ui64 txIdx = 0; txIdx < Transactions.size(); ++txIdx) {
1747-
const auto& tx = Transactions.at(txIdx);
1746+
for (ui64 txIdx = 0; txIdx < transactions.size(); ++txIdx) {
1747+
const auto& tx = transactions.at(txIdx);
17481748
const auto scheduledTaskCount = ScheduleByCost(tx, resourcesSnapshot);
17491749

17501750
for (ui64 stageIdx = 0; stageIdx < tx.Body->StagesSize(); ++stageIdx) {

ydb/core/kqp/executer_actor/kqp_tasks_graph.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -393,7 +393,7 @@ class TKqpTasksGraph : public NYql::NDq::TDqTasksGraph<TGraphMeta, TStageInfoMet
393393

394394
NYql::NDqProto::TDqTask* ArenaSerializeTaskToProto(const TTask& task, bool serializeAsyncIoSettings);
395395
void PersistTasksGraphInfo(NKikimrKqp::TQueryPhysicalGraph& result) const;
396-
void RestoreTasksGraphInfo(const TVector<NKikimrKqp::TKqpNodeResources>& resourcesSnapshot, const NKikimrKqp::TQueryPhysicalGraph& graphInfo);
396+
void RestoreTasksGraphInfo(const TVector<IKqpGateway::TPhysicalTxData>& transactions, const TVector<NKikimrKqp::TKqpNodeResources>& resourcesSnapshot, const NKikimrKqp::TQueryPhysicalGraph& graphInfo);
397397

398398
void FillChannelDesc(NYql::NDqProto::TChannel& channelDesc, const NYql::NDq::TChannel& channel,
399399
const NKikimrConfig::TTableServiceConfig::EChannelTransportVersion chanTransportVersion, bool enableSpilling) const;

0 commit comments

Comments
 (0)