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

Reply via email to