[CALCITE-6632] Wrong optimization because window missing constants in digest

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.39.0
• Component/s: core
• Labels: pull-request-available

Environment

• External issue URL: https://issues.apache.org/jira/browse/FLINK-15577
• Assignee: Jiajun Xie
• Reporter: Jiajun Xie
• Created: 6 days ago 02:45
• Updated: Yesterday 23:34
• Resolved: Yesterday 23:34

Description

Here is a simple case:

select sum(100) over (partition by deptno order by sal) as s -- window1
from emp
union all
select sum(1000) over(partition by deptno order by sal) as s -- window2
from emp 

window1 is different from window2.

But window digest missing constants, the window2 will be replaced by window1 after optimized.

LogicalUnion(all=[true])
  LogicalProject($0=[$2])
    LogicalWindow(window#0=[window(partition {1} order by [0] aggs [SUM($2)])]) -- window1 digest
      LogicalProject(SAL=[$5], DEPTNO=[$7])
        LogicalTableScan(table=[[CATALOG, SALES, EMP]])
  LogicalProject($0=[$2])
    LogicalWindow(window#0=[window(partition {1} order by [0] aggs [SUM($2)])]) -- window1 digest
      LogicalProject(SAL=[$5], DEPTNO=[$7])
        LogicalTableScan(table=[[CATALOG, SALES, EMP]]) 

Issue Links

• links to: GitHub Pull Request #4007