Hi Amit, Sorry I “unmounted” my playground, need to (find the time to) set it up again and I’ll be back to you.
Best, > On Sep 18, 2016, at 2:12 PM, Amit Sela <[email protected]> wrote: > > It appears that you did.. does this happen with the DirectRunner ? > Generally speaking, TextIO is a BoundedSource. I'm not if it's supported. > What's the stack trace ? Does the exception originate in Flink translation > code or Beam code ? That should provide a good hint. > > On Mon, Sep 19, 2016, 00:00 Emanuele Cesena <[email protected]> wrote: > 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 > > > > -- Emanuele Cesena, Data Eng. http://www.shopkick.com Il corpo non ha ideali
