You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "wangzeyu (Jira)" <ji...@apache.org> on 2021/04/12 06:45:00 UTC

[jira] [Created] (FLINK-22207) Hive Catalog retrieve Flink Properties error

wangzeyu created FLINK-22207:
--------------------------------

             Summary: Hive Catalog retrieve Flink Properties error
                 Key: FLINK-22207
                 URL: https://issues.apache.org/jira/browse/FLINK-22207
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Hive
    Affects Versions: 1.12.1
            Reporter: wangzeyu
             Fix For: 1.12.1


If we use hive catalog and set flink propertie eg."url",and then when we add the other propertie like start with string "flink." like "flink.url" will show we the error "java.lang.IllegalStateException: Duplicate key" , and what's worse is because of this error we can`t drop or alter this tabel more.

I found in this method , "org.apache.flink.table.catalog.hive.HiveCatalog.retrieveFlinkProperties", replace all "flink." of propertie. So , the  propertie of HiveCatalog "flink.url" and "flink.flink.url" both result to "url". 

I think in the method "org.apache.flink.table.catalog.hive.HiveCatalog.retrieveFlinkProperties" we should use replaceFirst but not replace to handle propertie.



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