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)
