一个flinkcdc到postgresql的问题

代码flinksql:

报错内容:

有没有遇到这种问题的朋友
Caused by: org.postgresql.util.PSQLException: ERROR: modification of distribution columns in OnConflictUpdate is not supported

你是否正确的建立上下游数据结构，比如sink的postgresql表是否正确建立主键约束

从报错来看， 不能对 postgres 表的分布键的字段进行更新，
查看一下postgres 表的建表语句，看看是否有这一句， distributed by()， 用于设置分布键