Hi, Thanks for the hint - I’ll debug better but I thought I did that: https://github.com/ecesena/beam-starter/blob/master/src/main/java/com/dataradiant/beam/examples/StreamWordCount.java#L140
Best, > On Sep 18, 2016, at 1:54 PM, Jean-Baptiste Onofré <[email protected]> wrote: > > Hi Emanuele > > You have to use a window to create a bounded collection from an unbounded > source. > > Regards > JB > > On Sep 18, 2016, 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
