附：修复连接：https://github.com/apache/flink-table-store/commit/c1b28985ce8bc8fb80fac96380edf3b34e4126b8
Best, Jingsong On Tue, Oct 11, 2022 at 3:27 PM Jingsong Li <jingsongl...@gmail.com> wrote: > > Hi RS, > > 这是bug，已经修复了 > > 建议使用即将发布的：0.2.1 > https://lists.apache.org/thread/n1yzpbxprnsh2m8swpsr40glt8h2b93v > > 具体的 jar > 包在这里：https://dist.apache.org/repos/dist/dev/flink/flink-table-store-0.2.1-rc2/ > > Best, > Jingsong > > On Tue, Oct 11, 2022 at 3:17 PM 李宇彬 <lixin58...@163.com> wrote: > > > > 方便贴下sql吗，我在flink 1.15 + fts 0.3.0-SNAPSHOT没复现出这个问题 > > > > > > 在2022年10月11日 09:19，RS<tinyshr...@163.com> 写道： > > Hi, > > > > > > 去除掉后运行是没有问题的，所以这种lib的冲突问题，能在官网上加个说明吗，避免后续其他人也遇到这种问题。 > > > > > > Thanks > > > > 在 2022-10-10 12:50:33，"yanfei lei" <fredia...@gmail.com> 写道： > > Hi, 从table store的pom中看，table store的dist包shade了一份connector-kafka。 > > https://repo1.maven.org/maven2/org/apache/flink/flink-table-store-dist/0.2.0/flink-table-store-dist-0.2.0.pom > > 把flink-connector-kafka-1.15.1.jar 去掉再试试？ > > > > > > RS <tinyshr...@163.com> 于2022年10月8日周六 17:19写道： > > > > Hi, > > 报错如下： > > > > > > [ERROR] Could not execute SQL statement. Reason: > > org.apache.flink.table.api.ValidationException: Multiple factories for > > identifier 'kafka' that implement > > 'org.apache.flink.table.factories.DynamicTableFactory' found in the > > classpath. > > > > > > Ambiguous factory classes are: > > > > > > org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableFactory > > org.apache.flink.table.store.kafka.KafkaLogStoreFactory > > > > org.apache.flink.table.store.shaded.streaming.connectors.kafka.table.KafkaDynamicTableFactory > > > > > > Thanks > > > > > > > > > > > > 在 2022-10-08 13:38:20，"Shammon FY" <zjur...@gmail.com> 写道： > > Hi RS > > 你这边能提供一下具体的冲突错误栈吗？ > > > > On Sat, Oct 8, 2022 at 8:54 AM RS <tinyshr...@163.com> wrote: > > > > Hi， > > > > > > 版本：flink-1.15.1 > > 使用table > > > > store，需要在lib下放置flink-table-store-dist-0.2.0.jar，之前集群的lib下有一个flink-connector-kafka-1.15.1.jar，使用sql-client，定义kafka源表的时候，发现connector冲突了 > > > > > > 是不是lib下有了flink-table-store-dist-0.2.0.jar，就不能有flink-connector-kafka-1.15.1.jar？ > > > > > > Thanks > >
