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 >>