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
> On Sep 18, 2016, at 21:04, Emanuele Cesena <emanu...@shopkick.com> wrote:
> I wrote a while ago about a simple example I was building to test KafkaIO:
> 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!
Emanuele Cesena, Data Eng.
Il corpo non ha ideali