[ https://issues.apache.org/jira/browse/FLINK-34301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813595#comment-17813595 ]
xuyang commented on FLINK-34301: -------------------------------- 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. > Release Testing Instructions: Verify FLINK-20281 Window aggregation supports > changelog stream input > --------------------------------------------------------------------------------------------------- > > Key: FLINK-34301 > URL: https://issues.apache.org/jira/browse/FLINK-34301 > Project: Flink > Issue Type: Sub-task > Components: Table SQL / API > Affects Versions: 1.19.0 > Reporter: lincoln lee > Assignee: xuyang > Priority: Blocker > Labels: release-testing > Fix For: 1.19.0 > > -- This message was sent by Atlassian Jira (v8.20.10#820010)