File tree Expand file tree Collapse file tree 2 files changed +5
-7
lines changed
ydb/core/kqp/executer_actor Expand file tree Collapse file tree 2 files changed +5
-7
lines changed Original file line number Diff line number Diff line change @@ -167,9 +167,7 @@ class TKqpExecuterBase : public TActor<TDerived> {
167
167
ArrayBufferMinFillPercentage = tableServiceConfig.GetArrayBufferMinFillPercentage ();
168
168
}
169
169
170
- if (tableServiceConfig.HasBufferPageAllocSize ()) {
171
- BufferPageAllocSize = tableServiceConfig.GetBufferPageAllocSize ();
172
- }
170
+ BufferPageAllocSize = tableServiceConfig.GetBufferPageAllocSize ();
173
171
174
172
EnableReadsMerge = *MergeDatashardReadsControl () == 1 ;
175
173
TasksGraph.GetMeta ().Snapshot = IKqpGateway::TKqpSnapshot (Request.Snapshot .Step , Request.Snapshot .TxId );
@@ -1028,7 +1026,7 @@ class TKqpExecuterBase : public TActor<TDerived> {
1028
1026
} else {
1029
1027
settings = *stageInfo.Meta .ResolvedSinkSettings ;
1030
1028
}
1031
-
1029
+
1032
1030
auto & lockTxId = TasksGraph.GetMeta ().LockTxId ;
1033
1031
if (lockTxId) {
1034
1032
settings.SetLockTxId (*lockTxId);
@@ -2339,7 +2337,7 @@ class TKqpExecuterBase : public TActor<TDerived> {
2339
2337
const NKikimrConfig::TTableServiceConfig::EBlockTrackingMode BlockTrackingMode;
2340
2338
const bool VerboseMemoryLimitException;
2341
2339
TMaybe<ui8> ArrayBufferMinFillPercentage;
2342
- TMaybe<ui8 > BufferPageAllocSize;
2340
+ TMaybe<ui64 > BufferPageAllocSize;
2343
2341
2344
2342
ui64 StatCollectInflightBytes = 0 ;
2345
2343
ui64 StatFinishInflightBytes = 0 ;
Original file line number Diff line number Diff line change @@ -65,7 +65,7 @@ class TKqpPlanner {
65
65
const std::shared_ptr<NKikimr::NKqp::NComputeActor::IKqpNodeComputeActorFactory>& CaFactory_;
66
66
const NKikimrConfig::TTableServiceConfig::EBlockTrackingMode BlockTrackingMode;
67
67
const TMaybe<ui8> ArrayBufferMinFillPercentage;
68
- const TMaybe<ui8 > BufferPageAllocSize;
68
+ const TMaybe<ui64 > BufferPageAllocSize;
69
69
const bool VerboseMemoryLimitException;
70
70
};
71
71
@@ -138,7 +138,7 @@ class TKqpPlanner {
138
138
TVector<TProgressStat> LastStats;
139
139
const NKikimrConfig::TTableServiceConfig::EBlockTrackingMode BlockTrackingMode;
140
140
const TMaybe<ui8> ArrayBufferMinFillPercentage;
141
- const TMaybe<ui8 > BufferPageAllocSize;
141
+ const TMaybe<ui64 > BufferPageAllocSize;
142
142
const bool VerboseMemoryLimitException;
143
143
144
144
public:
You can’t perform that action at this time.
0 commit comments