Details
-
Sub-task
-
Status: Closed
-
Blocker
-
Resolution: Fixed
-
1.19.0
Description
Window TVF aggregation supports changelog stream is ready for testing. User can add a window tvf aggregation as a down stream after CDC source or some nodes that will produce cdc records.
Someone can verify this feature with:
- Prepare a mysql table, and insert some data at first.
- Start sql-client and prepare ddl for this mysql table as a cdc source.
- You can verify the plan by `EXPLAIN PLAN_ADVICE` to check if there is a window aggregate node and the changelog contains "UA" or "UB" or "D" in its upstream.
- Use different kinds of window tvf to test window tvf aggregation while updating the source data to check the data correctness.
Attachments
Attachments
Issue Links
- is a clone of
-
FLINK-34301 Release Testing Instructions: Verify FLINK-20281 Window aggregation supports changelog stream input
- Closed