Jark Wu created FLINK-22160:
-------------------------------
Summary: Test Window TVF based aggregation and TopN
Key: FLINK-22160
URL: https://issues.apache.org/jira/browse/FLINK-22160
Project: Flink
Issue Type: Test
Components: Table SQL / API
Reporter: Jark Wu
Fix For: 1.13.0
In FLINK-19604
([FLIP-145|https://cwiki.apache.org/confluence/display/FLINK/FLIP-145%3A+Support+SQL+windowing+table-valued+function]),
we introduced a new syntax to express Window Aggregate and Window TopN. For
Window Aggregate, we have also introduced a new window kind: cumulate windows.
The scope of this task is to make sure:
1. The old window aggergate syntax ({{GROUP BY TUMBLE(...)}}) can be rewrite
using the new syntax, and get the same results. Note, session window is not
supported yet in the new syntax.
2. Verify the new CUMULATE window works as expect
3. Verify the new Window TopN workss as expect
4. Failure and recovery and rescale case: results are still correct.
5. Window emitting: window should be fired once watermark advances window end
(we can manually generate source data with monotonically and slowly increasing
timestamp)
6. The feature is well-documented
Note: the documentation for this feature is still going on (FLINK-22159), for
testing the feature, we can use the FLIP documentation as an instruction for
now.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
