[ https://issues.apache.org/jira/browse/FLINK-19829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jark Wu closed FLINK-19829. --------------------------- Resolution: Duplicate > should enclose column name in double quotes for PostgreSQL > ---------------------------------------------------------- > > Key: FLINK-19829 > URL: https://issues.apache.org/jira/browse/FLINK-19829 > Project: Flink > Issue Type: Bug > Components: Connectors / JDBC > Reporter: zl > Priority: Major > > when I run the sql in flink: > {code:sql} > 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{code} > the following exception happens: > {code:java} > Caused by: org.postgresql.util.PSQLException: ERROR: column "Name" of > relation "pg_sink" does not exist > ...{code} > 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 ? -- This message was sent by Atlassian Jira (v8.3.4#803005)