[
https://issues.apache.org/jira/browse/FLINK-22463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-22463:
-------------------------------
Affects Version/s: 1.13.0
> 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
> Affects Versions: 1.13.0
> Reporter: godfrey he
> Assignee: godfrey he
> Priority: Major
>
> 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)
