1.????????????????????????????????????????mysql binlog??????????????????200-3002.??????????????250??????400????????????1????????????????200-300?????????????????? 3.source??????????????????????????????????????????????
????????2 ??????????????id??????????????????RetractStream??timestamp??????KafkaTableSource??????rowtime ???? select order_id ,last_value(timestamp) timestamp,last_value(order_status) order_status from order group by order_id ??????over window ?????????????????? over(partition by df(timestamp,'yyyy-MM-dd 00:00:00') order by update_time range BETWEEN INTERVAL '24' hour preceding and current row ???? Exception in thread "main" org.apache.flink.table.api.TableException: Retraction on Over window aggregation is not supported yet. Note: Over window aggregation should not follow a non-windowed GroupBy aggregation. ?????? 1. ??????????????????sql???????????? 2.last_value(rowtime) as rowtime group by order_id ?????????????????????? (rowtime ????time attribute)????????????rowtime?????????????? watermark?? rowtime??????????????watermark??????????stream api ??operate????watermark????????????????????????
