Hi Emanuele

You have to use a window to create a bounded collection from an unbounded 
source.

Regards
JB



On Sep 18, 2016, 21:04, at 21:04, Emanuele Cesena <emanu...@shopkick.com> wrote:
>Hi,
>
>I wrote a while ago about a simple example I was building to test
>KafkaIO:
>https://github.com/ecesena/beam-starter/blob/master/src/main/java/com/dataradiant/beam/examples/StreamWordCount.java
>
>Issues with Flink should be fixed now, and I’m try to run the example
>on master and Flink 1.1.2.
>I’m currently getting:
>Caused by: java.lang.IllegalArgumentException: Write can only be
>applied to a Bounded PCollection
>
>What is the recommended way to go here?
>- is there a way to create a bounded collection from an unbounded one?
>- is there a plat to let TextIO write unbounded collections?
>- is there another recommended “simple sink” to use?
>
>Thank you much!
>
>Best,
>-- 
>Emanuele Cesena, Data Eng.
>http://www.shopkick.com
>
>Il corpo non ha ideali

Reply via email to