Re: 用代码执行flink sql 报错 Multiple factories for identifier 'jdbc' that implement

这个错误信息显示问题在后续版本已经修复，新版本发布后升级版本就能直接从错误信息中看到是哪些TableFactory冲突了: https://issues.apache.org/jira/browse/FLINK-20186 > 在 2020年12月3日，20:08，Wei Zhong 写道： > > Hi, > >

Re: 用代码执行flink sql 报错 Multiple factories for identifier 'jdbc' that implement

Hi, 现在的查找TableFactory的代码在错误信息显示上似乎存在问题，看不到真实的类名，可以先手动执行一下以下代码查看到底是哪些类被判定为JDBC的DynamicTableSinkFactory了： List result = new LinkedList<>(); ServiceLoader .load(Factory.class, Thread.currentThread().getContextClassLoader()) .iterator() .forEachRemaining(result::add); List jdbcResult =

Re:用代码执行flink sql 报错 Multiple factories for identifier 'jdbc' that implement

Hi, 你是用哪个版本的呢？有没有自己继承了 DynamicTableSinkFactory 实现的 factoryIdentifier 方法返回 `JDCB` 的 Connector？ Best, Hailong 在 2020-12-03 14:44:18，"xuzh" 写道： >错误： > > >Caused by: org.apache.flink.table.api.ValidationException: Multiple factories >for identifier 'jdbc' that implement