[ 
https://issues.apache.org/jira/browse/FLINK-18640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166059#comment-17166059
 ] 

毛宗良 commented on FLINK-18640:
-----------------------------

PostgresDialect has overrided the quoteIdentifier method and deleted the quote 
in the latest version 1.12. But it would thorow 'syntax error' when the table 
has columns named by reserved word, such as 'join'. So I removed the override 
in PostgresDialect in the pull request. The {color:#172b4d}quoteIdentifier 
{color}method in its parent class JdbcDialect is used to deal with the table 
names or columns named by reserved words, and it is written in the java doc. So 
I think the {color:#172b4d}PostgresDialect's override is not correct.{color}

> Flink jdbc not support postgresql with schema
> ---------------------------------------------
>
>                 Key: FLINK-18640
>                 URL: https://issues.apache.org/jira/browse/FLINK-18640
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / JDBC
>    Affects Versions: 1.9.1, 1.10.1
>            Reporter: 毛宗良
>            Priority: Major
>              Labels: pull-request-available
>
> Flink jdbc throw exceptions when read a postgresql table with scheam, like 
> "ods.t_test". BY debugging the source code, I found a bug about dealing the 
> table name.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to