[FLINK-19829] should enclose column name in double quotes for PostgreSQL

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Component/s: Connectors / JDBC
• Assignee: Unassigned
• Reporter: zhouli
• Created: 27/Oct/20 11:21
• Updated: 28/Oct/20 12:03
• Resolved: 28/Oct/20 12:02

Description

when I run the sql in flink:

create table pg_sink ( 
    Name VARCHAR, 
    address VARCHAR, 
    work VARCHAR) 
with (   
    'connector' = 'jdbc',   
    'url' = 'jdbc:postgresql://***:***/***',    
    'table-name' = 'pg_sink', 
    ...
) 

create table kafka_source(    
    Name VARCHAR,    
    address VARCHAR,    
    work VARCHAR
) with (    
    'connector.type' = 'kafka',    
    'format.type' = 'json',
    ...
)

insert into pg_sink select * from kafka_source

the following exception happens:

Caused by: org.postgresql.util.PSQLException: ERROR: column "Name" of relation "pg_sink" does not exist
...

we can solve this problem by remove method quoteIdentifier in PostgresDialect.java, then the method quoteIdentifier in JdbcDialect.java will be used to enclose the column name in double quotes for PostgreSQL. 

could assign this issue to me ?

Issue Links

• is duplicated by: FLINK-18640 Fix PostgresDialect doesn't quote the identifiers