Thanks for the feedback, we are currently in the middle of releasing 2.3.0 from pretty close to what is on Apache Beam master so your issue should be investigated before release.
On Wed, Jan 31, 2018 at 5:36 PM, Thomas Pelletier <tpellet...@zendesk.com> 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 >
