Re: Flink Kafka runtime error

2015-07-17 Thread Wendong
Hi Stephan, Thanks for your suggestion! I'll try the first solution too. Wendong -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-runtime-error-tp2063p2142.html Sent from the Apache Flink User Mailing List archive. mailing list a

Re: Flink Kafka runtime error

2015-07-17 Thread Stephan Ewen
Hi Wendong! The streaming connectors are not in Flink's "system classpath", because they depend on many libraries (zookeeper, asm, protocol buffers), and we want to keep the default dependencies slim. This reduces version conflicts for people where the user code depends on these libraries. As a c

Re: Flink Kafka runtime error

2015-07-15 Thread Wendong
Just found a workaround. I downloaded kafka_2.10-0.8.2.1.jar and flink-connector-kafka-0.9.0.jar, then put them into $FLINK_HOME/lib/. Now the runtime error is gone. But this is just a workaound. I believe there is a better solution. Wendong -- View this message in context: http://apache-flink