[
https://issues.apache.org/jira/browse/FLINK-39397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18077019#comment-18077019
]
Taranpreet Kaur commented on FLINK-39397:
-----------------------------------------
Hi [~taowang], can you please provide the error that you encountered while
deleting the record.
> postgres pk table encounted an error when delete a record
> ---------------------------------------------------------
>
> Key: FLINK-39397
> URL: https://issues.apache.org/jira/browse/FLINK-39397
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Affects Versions: cdc-3.6.0
> Reporter: Tao Wang
> Priority: Minor
> Attachments: image-2026-04-03-16-08-11-260.png
>
>
> source: postgress
> schema:
> {code:java}
> // code placeholder
> CREATE TABLE public."Upper_case_Test" (
> id int4 GENERATED BY DEFAULT AS IDENTITY NOT NULL,
> "name" varchar NULL,
> dt varchar NULL,
> col_add_1 varchar NULL,
> col_add_2 varchar NULL,
> CONSTRAINT newtable_pk PRIMARY KEY (id));
> {code}
>
>
> task.yaml
> {code:java}
> // code placeholder
> source:
> type: "postgres"
> hostname: "xxxxx"
> port: xxxx
> username: "xxxxx"
> password: "xxxxxx"
> tables: "postgres.public.Upper_case_Test"
> slot.name: "aaa"
> decoding.plugin.name: pgoutput
> schema-change.enabled: true
> scan.startup.mode: latest-offset
> ....
> ....
> pipeline:
> name: pg_2_mysql
> parallelism: 1
> schema.change.behavior: EVOLVE
> {code}
>
>
> !image-2026-04-03-16-08-11-260.png|width=992,height=495!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
