Skip to content

Commit 5c4df04

Browse files
committed
fixes applied to spilling enable
1 parent 985cdc2 commit 5c4df04

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

ydb/core/kqp/opt/kqp_opt_build_txs.cpp

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -495,16 +495,14 @@ class TKqpBuildTxsTransformer : public TSyncTransformerBase {
495495
{
496496
BuildTxTransformer = new TKqpBuildTxTransformer();
497497

498-
const bool enableSpillingGenericQuery =
499-
kqpCtx->IsGenericQuery() && config->SpillingEnabled() &&
500-
config->EnableSpillingGenericQuery;
498+
config->EnableSpillingGenericQuery &= (kqpCtx->IsGenericQuery() && config->SpillingEnabled());
501499

502500
DataTxTransformer = TTransformationPipeline(&typesCtx)
503501
.AddServiceTransformers()
504502
.Add(TExprLogTransformer::Sync("TxOpt", NYql::NLog::EComponent::ProviderKqp, NYql::NLog::ELevel::TRACE), "TxOpt")
505503
.Add(*TypeAnnTransformer, "TypeAnnotation")
506504
.AddPostTypeAnnotation(/* forSubgraph */ true)
507-
.Add(CreateKqpBuildPhyStagesTransformer(enableSpillingGenericQuery, typesCtx, config->BlockChannelsMode), "BuildPhysicalStages")
505+
.Add(CreateKqpBuildPhyStagesTransformer(config->EnableSpillingGenericQuery, typesCtx, config->BlockChannelsMode), "BuildPhysicalStages")
508506
// TODO(ilezhankin): "BuildWideBlockChannels" transformer is required only for BLOCK_CHANNELS_FORCE mode.
509507
.Add(CreateKqpBuildWideBlockChannelsTransformer(typesCtx, config->BlockChannelsMode), "BuildWideBlockChannels")
510508
.Add(*BuildTxTransformer, "BuildPhysicalTx")

0 commit comments

Comments
 (0)