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 <amitsel...@gmail.com> 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 <emanu...@shopkick.com> 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é <j...@nanthrax.net> 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 <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
> 
> 
> 
> 

-- 
Emanuele Cesena, Data Eng.
http://www.shopkick.com

Il corpo non ha ideali




Reply via email to