这个很明显是jar包冲突了 只保留flink-sql那个包就行了
| |
JasonLee
|
|
邮箱：17610775...@163.com
|
Signature is customized by Netease Mail Master
On 07/15/2020 10:48, dmt312_2010 wrote:
Hi,
大家好，请教各位大佬一个问题，我在验证flink 1.11.0时，遇到如下问题：
报错信息：
[ERROR] Could not execute SQL statement. Reason:
java.lang.NoSuchMethodError:
Hi,
两个kafka connector是会冲突的，还有一点是 SQL client 里应该用 sql 的connector依赖吧，
flink-sql-connector-kafka_2.12-1.11.0.jar
祝好，
Leonard Xu
> 在 2020年7月15日，10:56，Paul Lam 写道：
>
> Hi,
>
> 看起来是 Kafka connector class 冲突了，flink-connector-kafka_2.12-1.11.0.jar 和
> flink-connector-kafka-0.10_2.12-1.11.0.jar 不能同时
Hi,
看起来是 Kafka connector class 冲突了，flink-connector-kafka_2.12-1.11.0.jar 和
flink-connector-kafka-0.10_2.12-1.11.0.jar 不能同时加到 classpath 里。
Best,
Paul Lam
> 2020年7月15日 10:48，dmt312_2010 写道：
>
> Hi,
> 大家好，请教各位大佬一个问题，我在验证flink 1.11.0时，遇到如下问题：
>
>
> 报错信息：
>
>
> [ERROR] Could not execute SQL st
Hi,
大家好，请教各位大佬一个问题，我在验证flink 1.11.0时，遇到如下问题：
报错信息：
[ERROR] Could not execute SQL statement. Reason:
java.lang.NoSuchMethodError:
org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerThread.(Lorg/slf4j/Logger;Lorg/apache/flink/streaming/connectors/kafka/internal/Handover;Ljava/util
