You have to use a window to create a bounded collection from an unbounded
On Sep 18, 2016, 21:04, at 21:04, Emanuele Cesena <emanu...@shopkick.com> wrote:
>I wrote a while ago about a simple example I was building to test
>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