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
