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)
Locked
