[
https://issues.apache.org/jira/browse/FLINK-19829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222117#comment-17222117
]
Jark Wu commented on FLINK-19829:
---------------------------------
Hi [~Leo Zhou], thanks for reporting this issue. This is a known issue.
Adding back the quotes around identifiers in PostgresDialect will have other
problems (e.g. can't distinguish schema part).
Let's continue the discussion in FLINK-18640.
> 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)
