flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Wendong <wendong....@gmail.com>
Subject Re: Flink Kafka example in Scala
Date Fri, 17 Jul 2015 22:23:32 GMT
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.

Mime
View raw message