summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorivanmorozov <[email protected]>2023-02-03 15:53:19 +0300
committerivanmorozov <[email protected]>2023-02-03 15:53:19 +0300
commit5a2ccd9a130b0d211c4157701e150b7ef540e5ce (patch)
tree98ac6871ba1995b8abd0f56a25bbb334e9380fb6
parent5d2f4b4034904b4f15593fb18c250210ca60a6a2 (diff)
fix for aggregation with session
-rw-r--r--ydb/library/yql/core/yql_aggregate_expander.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/library/yql/core/yql_aggregate_expander.cpp b/ydb/library/yql/core/yql_aggregate_expander.cpp
index f83350fe924..55839feac11 100644
--- a/ydb/library/yql/core/yql_aggregate_expander.cpp
+++ b/ydb/library/yql/core/yql_aggregate_expander.cpp
@@ -1347,7 +1347,7 @@ TExprNode::TPtr TAggregateExpander::GeneratePostAggregate(const TExprNode::TPtr&
{
auto preprocessLambda = GeneratePreprocessLambda(keyExtractor);
TExprNode::TPtr postAgg;
- if (!UsePartitionsByKeys && UseFinalizeByKeys) {
+ if (!UsePartitionsByKeys && UseFinalizeByKeys && !HaveSessionSetting) {
postAgg = Ctx.Builder(Node->Pos())
.Callable("ShuffleByKeys")
.Add(0, std::move(preAgg))