[jira] [Created] (FLINK-22463) IllegalArgumentException is thrown in WindowAttachedWindowingStrategy when two phase is enabled for distinct agg

[Shang Yuanchun (Jira)]

godfrey he created FLINK-22463:
----------------------------------

             Summary: IllegalArgumentException is thrown in WindowAttachedWindowingStrategy when two phase is enabled for distinct agg
                 Key: FLINK-22463
                 URL: https://issues.apache.org/jira/browse/FLINK-22463
             Project: Flink
          Issue Type: Bug
            Reporter: godfrey he


Caused by: java.lang.IllegalArgumentException
        at org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:122)
        at org.apache.flink.table.planner.plan.logical.WindowAttachedWindowingStrategy.<init>(WindowAttachedWindowingStrategy.java:51)
        at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
        at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
        at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
        at java.lang.reflect.Constructor.newInstance(Constructor.java:423)


The reason is the {{windowStart}} may be {{-1}} when two phase is enabled for distinct agg, see [TwoStageOptimizedWindowAggregateRule.java#L143|https://github.com/apache/flink/blob/a3363b91b144edfbae5ab114984ded622d3f8fbc/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/TwoStageOptimizedWindowAggregateRule.java#L143]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)