flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gyula Fóra <gyula.f...@gmail.com>
Subject Re: Flink Kafka example in Scala
Date Thu, 16 Jul 2015 17:44:36 GMT
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.zhu@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.
>

Mime
View raw message