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 Thu, 16 Jul 2015 04:36:37 GMT
I tried, but got error:

[error] TestKafka.scala:11: object scala is not a member of package
org.apache.flink.streaming.api
[error] import org.apache.flink.streaming.api.scala._

So I switched back to my original import statements.

Now I changed SimpleStringSchema to JavaDefaultStringSchema in addSink(new
KafkaSink(...)), then compilation error was gone. 

The problem is that there is runtime error:

org.apache.flink.client.program.ProgramInvocationException: The main method
caused an error.
        at
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:452)
        at
org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:353)
        at org.apache.flink.client.program.Client.run(Client.java:315)
        at
org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:584)
        at org.apache.flink.client.CliFrontend.run(CliFrontend.java:290)
        at
org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:880)
        at org.apache.flink.client.CliFrontend.main(CliFrontend.java:922)
Caused by: java.lang.RuntimeException:* Data stream sinks cannot be copied*
        at
org.apache.flink.streaming.api.datastream.DataStreamSink.copy(DataStreamSink.java:43)
        at
org.apache.flink.streaming.api.datastream.DataStreamSink.copy(DataStreamSink.java:30)
        at
org.apache.flink.streaming.api.datastream.DataStream.addSink(DataStream.java:1341)
        at
org.apache.flink.streaming.api.datastream.DataStream.print(DataStream.java:1029)
...........

Googled the error message but didn't find useful information. 

Anyone can shed some light?

Thanks!

Wendong




--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-example-in-Scala-tp2069p2071.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Mime
View raw message