diff options
| author | aneporada <aneporada@ydb.tech> | 2023-06-09 13:17:38 +0300 |
|---|---|---|
| committer | aneporada <aneporada@ydb.tech> | 2023-06-09 13:17:38 +0300 |
| commit | be521d3ff04fca2a5fc67baad12a6e9b1da6b773 (patch) | |
| tree | 6a720edfb5c05ede390af0b27fe1db73c9af0735 | |
| parent | e2aabcfad3b78847a46f0a30bd5bd21b3471e883 (diff) | |
| download | ydb-be521d3ff04fca2a5fc67baad12a6e9b1da6b773.tar.gz | |
Fix Aggregate over Aggregate optimizer (was broken on SessionWindow)
initial
| -rw-r--r-- | ydb/library/yql/core/common_opt/yql_co_simple1.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/ydb/library/yql/core/common_opt/yql_co_simple1.cpp b/ydb/library/yql/core/common_opt/yql_co_simple1.cpp index e9770df97df..2b2c580a51f 100644 --- a/ydb/library/yql/core/common_opt/yql_co_simple1.cpp +++ b/ydb/library/yql/core/common_opt/yql_co_simple1.cpp @@ -3032,7 +3032,8 @@ TExprNode::TPtr NormalizeFrames(TCoCalcOverWindowGroup node, TExprContext& ctx) } bool HasPayload(const TCoAggregate& node) { - return node.Handlers().Size() > 0 || HasSetting(node.Settings().Ref(), "hopping"); + return node.Handlers().Size() > 0 || HasSetting(node.Settings().Ref(), "hopping") || + HasSetting(node.Settings().Ref(), "session"); } TExprNode::TPtr PullAssumeColumnOrderOverEquiJoin(const TExprNode::TPtr& node, TExprContext& ctx, TOptimizeContext& optCtx) { |