[
https://issues.apache.org/jira/browse/FLINK-22207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-22207.
------------------------------
Fix Version/s: (was: 1.12.1)
1.13.0
Assignee: wangzeyu
Resolution: Fixed
fixed: c29ee91abdb092f8dca5274a6628b71e88b57485
> 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
> Assignee: wangzeyu
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.13.0
>
>
> 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)
