Thanks for the example code! I'll try it out.
Wendong
--
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-tp2199p2294.html
Sent from the Apache Flink User Mailing List archive
in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-cannot-find-org-I0Itec-zkclient-serialize-ZkSerializer-tp2199p2285.html
Sent from the Apache Flink User Mailing List archive. mailing list archive
at Nabble.com.
-archive.2336050.n4.nabble.com/Flink-Kafka-cannot-find-org-I0Itec-zkclient-serialize-ZkSerializer-tp2199p2285.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-cannot-find-org-I0Itec-zkclient-serialize-ZkSerializer-tp2199p2271.html
Sent from the Apache Flink User Mailing List archive. mailing list archive
at Nabble.com.
--
addSbtPlugin(com.eed3si9n % sbt-assembly % 0.12.0)
//- End project/assembly.sbt --
--
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-tp2199p2271
in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-cannot-find-org-I0Itec-zkclient-serialize-ZkSerializer-tp2199p2218.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
.2336050.n4.nabble.com/Flink-Kafka-cannot-find-org-I0Itec-zkclient-serialize-ZkSerializer-tp2199p2220.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
-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.
(URLClassLoader.java:366)
.
I already put zkclient-0.5.jar under flink_root_dir/lib. Anyone can shed
some light?
Thanks for help!
Wendong
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-cannot-find-org-I0Itec-zkclient-serialize
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
10 matches
Mail list logo