beam-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Emanuele Cesena <>
Subject Issues with simple KafkaIO-read pipeline -- where to write?
Date Sun, 18 Sep 2016 19:04:19 GMT

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
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

View raw message