Sorry I “unmounted” my playground, need to (find the time to) set it up again
and I’ll be back to you.
> 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:
> Thanks for the hint - I’ll debug better but I thought I did that:
> > 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.
> Il corpo non ha ideali
Emanuele Cesena, Data Eng.
Il corpo non ha ideali