Hey, The reason you are getting that error is because you are calling print after adding a sink, which is an invalid operation. Remove either addSink or print :) Cheers, Gyula
On Thu, Jul 16, 2015 at 7:37 PM Wendong <wendong....@gmail.com> wrote: > Thanks! I tried your updated MySimpleStringSchema and it works for both > source and sink. > > However, my problem is the runtime error "Data stream sinks cannot be > copied" as listed in previous post. I hope someone ran into the problem > before and can give a hint. > > Wendong > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-example-in-Scala-tp2069p2109.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
