在Postgres中,当我们尝试用相同的唯一键组合重新插入记录时,会抛出唯一键禁忌错误。create table DUMMY( ONE integer autoincrement start 1 increment 1, TWO integer NOT NULL, THREE varchar(7)NOT NULL, FOUR varchar(7) NOT NULL )
ALTER TABLE DUMMY ADD CONSTRAINT UNIQUENESS UNIQUE(TWO, THREE
我们的使用是,我们希望使用flink流的去复制作业,它从源读取它的数据(kafka主题),并将独特的记录写入hdfs文件接收器。因此,我决定使用flink键状态流来实现去复制。toString) env.execute(applicationName)下面是使用flink的值状态进行去复制的代码with this key again }}