Skip to content

Commit 2ca4a8d

Browse files
committed
Fixed pragma name
1 parent 3fdb9dd commit 2ca4a8d

File tree

4 files changed

+4
-4
lines changed

4 files changed

+4
-4
lines changed

Diff for: ydb/core/kqp/provider/yql_kikimr_settings.cpp

+1-1
Original file line numberDiff line numberDiff line change
@@ -100,7 +100,7 @@ TKikimrConfiguration::TKikimrConfiguration() {
100100
REGISTER_SETTING(*this, MaxDPHypDPTableSize);
101101

102102
REGISTER_SETTING(*this, MaxTasksPerStage);
103-
REGISTER_SETTING(*this, DataSizePerJob);
103+
REGISTER_SETTING(*this, DataSizePerPartition);
104104
REGISTER_SETTING(*this, MaxSequentialReadsInFlight);
105105

106106
REGISTER_SETTING(*this, KMeansTreeSearchTopSize);

Diff for: ydb/core/kqp/provider/yql_kikimr_settings.h

+1-1
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ struct TKikimrSettings {
7676
NCommon::TConfSetting<ui32, false> MaxDPHypDPTableSize;
7777

7878
NCommon::TConfSetting<ui32, false> MaxTasksPerStage;
79-
NCommon::TConfSetting<ui64, false> DataSizePerJob;
79+
NCommon::TConfSetting<ui64, false> DataSizePerPartition;
8080
NCommon::TConfSetting<ui32, false> MaxSequentialReadsInFlight;
8181

8282
NCommon::TConfSetting<ui32, false> KMeansTreeSearchTopSize;

Diff for: ydb/core/kqp/query_compiler/kqp_query_compiler.cpp

+1-1
Original file line numberDiff line numberDiff line change
@@ -1106,7 +1106,7 @@ class TKqpQueryCompiler : public IKqpQueryCompiler {
11061106
IDqIntegration::TPartitionSettings pSettings;
11071107
pSettings.MaxPartitions = maxTasksPerStage;
11081108
pSettings.CanFallback = false;
1109-
pSettings.DataSizePerJob = Config->DataSizePerJob.Get().GetOrElse(NYql::TDqSettings::TDefault::DataSizePerJob);
1109+
pSettings.DataSizePerJob = Config->DataSizePerPartition.Get().GetOrElse(NYql::TDqSettings::TDefault::DataSizePerJob);
11101110
dqIntegration->Partition(*source, partitionParams, &clusterName, ctx, pSettings);
11111111
externalSource.SetTaskParamKey(TString(dataSourceCategory));
11121112
for (const TString& partitionParam : partitionParams) {

Diff for: ydb/tests/fq/yt/kqp_yt_import/test_yt_reading.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ def test_partitioned_reading(self, kqp_run: KqpRun):
99
add_sample_table(kqp_run)
1010

1111
kqp_run.add_query("""
12-
PRAGMA ydb.DataSizePerJob = "1";
12+
PRAGMA ydb.DataSizePerPartition = "1";
1313
1414
SELECT * FROM plato.input
1515
""")

0 commit comments

Comments
 (0)