changlog-json??????????

Sun, 15 Nov 2020 22:27:58 -0800 

Hi,??????????
????????????????????
??????????????????????????????
????SQL????????
select memberid, shop_time, workerid, resource_type, proctime
from(
    select memberid, shop_time, workerid, resource_type, proctime
    from inviteShop
    where shop_time >= DATE_FORMAT(LOCALTIMESTAMP, 
'yyyy-MM-dd')
) t0
inner join
(
    select memberid, min(shop_time) as shop_time
    from inviteShop
    where shop_time >= DATE_FORMAT(LOCALTIMESTAMP, 'yyyy-MM-dd')
    group by memberid
) t1 on t0.memberid = t1.memberid and t0.shop_time = t1.shop_time 



??????????????????????????????????????????inviteShop??????Kafka????Changelog-json????????????????????????????????????????????????????????????????
Best
SELECT [column_list] FROM (    SELECT [column_list],      ROW_NUMBER() OVER 
([PARTITION BY col1[, col2...]]        ORDER BY time_attr [asc|desc]) AS rownum 
   FROM table_name) WHERE rownum = 1org.apache.flink.table.api.TableException: 
Deduplicate doesn't support consuming update and delete changes which is 
produced by node TableSourceScan

回复