[
https://issues.apache.org/jira/browse/FLINK-20186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-20186:
--------------------------------
Description:
I was playing with user-defined connectors when I found the following error
message:
{code}
Caused by: org.apache.flink.table.api.ValidationException: Multiple factories
for identifier 'odps' that implement
'org.apache.flink.table.factories.DynamicTableFactory' found in the classpath.
Ambiguous factory classes are:
java.util.LinkedList
java.util.LinkedList
java.util.LinkedList
java.util.LinkedList
java.util.LinkedList
java.util.LinkedList
at
org.apache.flink.table.factories.FactoryUtil.discoverFactory(FactoryUtil.java:258)
at
org.apache.flink.table.factories.FactoryUtil.getDynamicTableFactory(FactoryUtil.java:370)
... 71 more
{code}
This is caused by {{FactoryUtil.java}} line 265, where {{.map(f ->
factories.getClass().getName())}} should be {{.map(f ->
f.getClass().getName())}}
was:
I was playing with user-defined connectors when I found the following error
message:
```
Caused by: org.apache.flink.table.api.ValidationException: Multiple factories
for identifier 'odps' that implement
'org.apache.flink.table.factories.DynamicTableFactory' found in the classpath.
Ambiguous factory classes are:
java.util.LinkedList
java.util.LinkedList
java.util.LinkedList
java.util.LinkedList
java.util.LinkedList
java.util.LinkedList
at
org.apache.flink.table.factories.FactoryUtil.discoverFactory(FactoryUtil.java:258)
at
org.apache.flink.table.factories.FactoryUtil.getDynamicTableFactory(FactoryUtil.java:370)
... 71 more
```
This is caused by {{FactoryUtil.java}} line 265, where {{.map(f ->
factories.getClass().getName())}} should be {{.map(f ->
f.getClass().getName())}}
> FactoryUtil will give an incorrect error message when multiple factories fit
> the connector identifier
> -----------------------------------------------------------------------------------------------------
>
> Key: FLINK-20186
> URL: https://issues.apache.org/jira/browse/FLINK-20186
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / API
> Affects Versions: 1.12.0, 1.11.2
> Reporter: Caizhi Weng
> Priority: Major
> Fix For: 1.12.0
>
>
> I was playing with user-defined connectors when I found the following error
> message:
> {code}
> Caused by: org.apache.flink.table.api.ValidationException: Multiple factories
> for identifier 'odps' that implement
> 'org.apache.flink.table.factories.DynamicTableFactory' found in the classpath.
> Ambiguous factory classes are:
> java.util.LinkedList
> java.util.LinkedList
> java.util.LinkedList
> java.util.LinkedList
> java.util.LinkedList
> java.util.LinkedList
> at
> org.apache.flink.table.factories.FactoryUtil.discoverFactory(FactoryUtil.java:258)
> at
> org.apache.flink.table.factories.FactoryUtil.getDynamicTableFactory(FactoryUtil.java:370)
> ... 71 more
> {code}
> This is caused by {{FactoryUtil.java}} line 265, where {{.map(f ->
> factories.getClass().getName())}} should be {{.map(f ->
> f.getClass().getName())}}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
