当在代码中使用Flink1.11.0版本时，如果将一个changelog的数据源insert到一个upsertsink时报错

已付费购买专栏的朋友&＃xff0c;请在申请查看权限时&＃xff0c;备注你的CSDN名称才能通过查看权限&＃xff0c;谢谢配合&＃xff0c;谢谢理解。如果未购买&＃xff0c;请先购买专栏&＃xff0c;再申请查看权限。

报错如下&＃xff1a;

[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.TableException: Provided trait [BEFORE_AND_AFTER] can&＃39;t satisfy required trait [ONLY_UPDATE_AFTER]. This is a bug in planner, please file an issue.
Current node is TableSourceScan(table&＃61;[[default_catalog, default_database, t_pick_order]], fields&＃61;[order_no, status])


更多内容请查看以下链接&＃xff1a;

【腾讯文档】当在代码中使用Flink1.11.0版本时&＃xff0c;如果将一个change-log的数据源insert到一个upsert sink时报错