zl created FLINK-19829:
--------------------------
Summary: 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
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)
