Flink CDC Issue Import created FLINK-34805:
----------------------------------------------
Summary: [Bug] About PostgresSql snapshot sql
Key: FLINK-34805
URL: https://issues.apache.org/jira/browse/FLINK-34805
Project: Flink
Issue Type: Bug
Components: Flink CDC
Reporter: Flink CDC Issue Import
### Search before asking
- [X] I searched in the
[issues|https://github.com/ververica/flink-cdc-connectors/issues] and found
nothing similar.
### Flink version
1.14.6
### Flink CDC version
2.4.1
### Database and its version
PostgreSQL 13.2
### Minimal reproduce step
In the version of flink-connector-postgres-cdc 2.4.1, snapshot SQL is
generated during a full snapshot and is split according to the command of
key,When running POSTGRESQL SQL, the column will be case-sensitive. But in
fact, when the SQL is generated, double quotation marks are not added to this
column. Therefore POSTGRESQL converts this column to lowercase, and lead to
POSTGRESQL cannot identify this column, resulting in an error.
![638901E5-7EC3-41D2-88F6-8AA4D12D54FE|https://github.com/ververica/flink-cdc-connectors/assets/94167908/7448282b-9f72-4512-b433-6a9c19bb7f6e]
package com.ververica.cdc.connectors.postgres.source.utils;
![6027352F-2643-4D3B-9D75-4CE712CBAC27|https://github.com/ververica/flink-cdc-connectors/assets/94167908/4d4d0084-a5e9-49c7-8812-8da0df8f489b]
![9966F5AB-0E48-4600-8BC6-FDF6480E7297|https://github.com/ververica/flink-cdc-connectors/assets/94167908/f937df43-d277-4495-8ca9-24460e967ece]
### What did you expect to see?
“key”
### What did you see instead?
key
### Anything else?
_No response_
### Are you willing to submit a PR?
- [X] I'm willing to submit a PR!
---------------- Imported from GitHub ----------------
Url: https://github.com/apache/flink-cdc/issues/2375
Created by: [linzhicong1996|https://github.com/linzhicong1996]
Labels: bug,
Created at: Tue Aug 08 20:13:07 CST 2023
State: open
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
