You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "zl (Jira)" <ji...@apache.org> on 2020/10/28 11:06:00 UTC
[jira] [Commented] (FLINK-19829) should enclose column name in
double quotes for PostgreSQL
[ https://issues.apache.org/jira/browse/FLINK-19829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222101#comment-17222101 ]
zl commented on FLINK-19829:
----------------------------
Hi [~jark], can you take a look at this issue ?
> 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)