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 <[email protected]> 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
