Hi！
window tvf 目前不支持消费 changelog，也就是说只能消费 insert 数据。upsert-kafka source 是一个会产生
changelog 的 source，因此下游不能接 window tvf。
赵旭晨 于2022年3月1日周二 15:23写道：
> sql如下：
> with effective_chargeorder as (
> select
> o.recordcreatedtime,o.recordcreateduser,o.status,o._is_delete,o.appointmentid,
>
sql如下：
with effective_chargeorder as (
select
o.recordcreatedtime,o.recordcreateduser,o.status,o._is_delete,o.appointmentid,o.id,o.tenantid,o.actualprice,o.proc_time
from t_k_chargeorder as o
where o.recordcreateduser > 0 and o.status NOT IN ( '已作废', '未收费', '作废并撤回',
'等待支付宝付费', '等待微信付费' )
and
sql如下：
with effective_chargeorder as (
select
o.recordcreatedtime,o.recordcreateduser,o.status,o._is_delete,o.appointmentid,o.id,o.tenantid,o.actualprice,o.proc_time
from t_k_chargeorder as o
where o.recordcreateduser > 0 and o.status NOT IN ( '已作废', '未收费', '作废并撤回',
'等待支付宝付费', '等待微信付费' )
and
