[jira] [Created] (FLINK-12182) AggregateProjectMergeRule can not handle LogicalWindowAggregate

[Shang Yuanchun (Jira)]

Hequn Cheng created FLINK-12182:
-----------------------------------

             Summary: AggregateProjectMergeRule can not handle LogicalWindowAggregate
                 Key: FLINK-12182
                 URL: https://issues.apache.org/jira/browse/FLINK-12182
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / API
            Reporter: Hequn Cheng
            Assignee: Hequn Cheng


Currently, we add the AggregateProjectMergeRule.INSTANCE in logical rule sets and use it to remove project for aggregates. However, there are some bugs when this rule be applied for the LogicalWindowAggregate.

When the project was removed, the input field names are changed, so the rule has to update all fields in the Aggregate, while the field name in LogicalWindow in LogicalWindowAggregate has not taken into consideration in AggregateProjectMergeRule, as it is a rule in Calcite.

As a quick fix, I think we can change
{code:java}
AggregateProjectMergeRule.INSTANCE,
{code}
to
{code:java}
    new AggregateProjectMergeRule(
      classOf[LogicalAggregate], classOf[Project], RelFactories.LOGICAL_BUILDER),
{code}

Of course, we need a complete solution for the LogicalWindowAggregate, but not in this jira.

Any suggestions are welcomed!





--
This message was sent by Atlassian JIRA
(v7.6.3#76005)