flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Maximilian Michels <...@apache.org>
Subject Re: Flink Kafka cannot find org/I0Itec/zkclient/serialize/ZkSerializer
Date Tue, 21 Jul 2015 08:21:05 GMT
Hi,

Are you running this locally or in a cluster environment? Did you put the
zkClient-0.5.jar in the /lib directory of every node (also task managers)?

It seems like sbt should include the zkClient dependency in the fat jar. So
there might be something wrong with your build process.

Best regards,
Max

On Tue, Jul 21, 2015 at 7:10 AM, Wendong <wendong.zhu@gmail.com> wrote:

> to be specific, the error occurs at:
>
>
> org.apache.flink.*streaming.connectors.kafka.api.KafkaSource.initializeConnection*(KafkaSource.java:175)
>
>
>
> --
> View this message in context:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-cannot-find-org-I0Itec-zkclient-serialize-ZkSerializer-tp2199p2200.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>

Mime
View raw message