Hi Thomas, Weird as the validate runner tests worked and we use TextIO there.
Let me try to reproduce. Thanks for the report ! Regards JB On 02/01/2018 02:36 AM, Thomas Pelletier wrote: > Hi, > > I'm trying to run a pipeline containing just a TextIO.read() step on a Flink > cluster, using the latest Beam git revision (ff37337 > <https://github.com/apache/beam/commit/ff37337d85aa5af23418f3be4611b913395ccc88>). > The job fails to start with the Exception: > > java.lang.UnsupportedOperationException: The transform is currently not > supported. > > It does work with Beam 2.2.0 though. All code, logs, and reproduction steps on > this repository <https://github.com/pelletier/beam-flink-example>. > > Any idea what might be going on? > > Thanks, > Thomas -- Jean-Baptiste Onofré [email protected] http://blog.nanthrax.net Talend - http://www.talend.com
