diff options
author | ivanmorozov <[email protected]> | 2023-02-03 15:53:19 +0300 |
---|---|---|
committer | ivanmorozov <[email protected]> | 2023-02-03 15:53:19 +0300 |
commit | 5a2ccd9a130b0d211c4157701e150b7ef540e5ce (patch) | |
tree | 98ac6871ba1995b8abd0f56a25bbb334e9380fb6 | |
parent | 5d2f4b4034904b4f15593fb18c250210ca60a6a2 (diff) |
fix for aggregation with session
-rw-r--r-- | ydb/library/yql/core/yql_aggregate_expander.cpp | 2 |
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)) |