Hi Aljoscha,
Yes, the flink-connector-kafka jar file is under Flink lib directory:
flink-0.9.0/lib/flink-connector-kafka-0.9.0.jar
and it shows KafkaSink class exists:
$ jar tf lib/flink-connector-kafka-0.9.0.jar | grep KafkaSink
org/apache/flink/streaming/connectors/kafka/api/KafkaSink.class
I cannot think of any reason why KafkaSink not found:
.........
Caused by: java.lang.Exception: Call to registerInputOutput() of invokable
failed
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:504)
.......
Caused by: org.apache.flink.streaming.runtime.tasks.StreamTaskException:
*Cannot instantiate user function*.
at
org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(StreamConfig.java:185)
.......
Caused by: java.lang.ClassNotFoundException:
org.apache.flink.streaming.connectors.kafka.api.*KafkaSink*
at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
Any clue?
Thanks,
Wendong
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-example-in-Scala-tp2069p2143.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
