Skip to content

Commit

Permalink
Merge af0f6fb into 985cdc2
Browse files Browse the repository at this point in the history
  • Loading branch information
gridnevvvit authored Oct 18, 2024
2 parents 985cdc2 + af0f6fb commit 0c35e73
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 6 deletions.
6 changes: 2 additions & 4 deletions ydb/core/kqp/opt/kqp_opt_build_txs.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -495,16 +495,14 @@ class TKqpBuildTxsTransformer : public TSyncTransformerBase {
{
BuildTxTransformer = new TKqpBuildTxTransformer();

const bool enableSpillingGenericQuery =
kqpCtx->IsGenericQuery() && config->SpillingEnabled() &&
config->EnableSpillingGenericQuery;
config->EnableSpillingGenericQuery &= (kqpCtx->IsGenericQuery() && config->SpillingEnabled());

DataTxTransformer = TTransformationPipeline(&typesCtx)
.AddServiceTransformers()
.Add(TExprLogTransformer::Sync("TxOpt", NYql::NLog::EComponent::ProviderKqp, NYql::NLog::ELevel::TRACE), "TxOpt")
.Add(*TypeAnnTransformer, "TypeAnnotation")
.AddPostTypeAnnotation(/* forSubgraph */ true)
.Add(CreateKqpBuildPhyStagesTransformer(enableSpillingGenericQuery, typesCtx, config->BlockChannelsMode), "BuildPhysicalStages")
.Add(CreateKqpBuildPhyStagesTransformer(config->EnableSpillingGenericQuery, typesCtx, config->BlockChannelsMode), "BuildPhysicalStages")
// TODO(ilezhankin): "BuildWideBlockChannels" transformer is required only for BLOCK_CHANNELS_FORCE mode.
.Add(CreateKqpBuildWideBlockChannelsTransformer(typesCtx, config->BlockChannelsMode), "BuildWideBlockChannels")
.Add(*BuildTxTransformer, "BuildPhysicalTx")
Expand Down
4 changes: 2 additions & 2 deletions ydb/core/protos/table_service_config.proto
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ message TTableServiceConfig {

message TSpillingServiceConfig {
message TLocalFileConfig {
optional bool Enable = 1 [default = true];
optional bool Enable = 1 [default = false];
optional string Root = 2 [default = ""];
optional uint64 MaxTotalSize = 3 [default = 21474836480]; // 20 GiB
optional uint64 MaxFileSize = 4 [default = 5368709120]; // 5 GiB
Expand Down Expand Up @@ -309,7 +309,7 @@ message TTableServiceConfig {

optional bool EnableImplicitQueryParameterTypes = 66 [ default = false ];

optional string EnableSpillingNodes = 67 [ default = "All" ];
optional string EnableSpillingNodes = 67 [ default = "None" ];

message TComputeSchedulerSettings {
optional uint64 AdvanceTimeIntervalUsec = 1 [default = 50000];
Expand Down

0 comments on commit 0c35e73

Please sign in to comment.