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
