[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)
[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=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)