TextIO operation not supported by Flink for Beam master

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 ). The job fails to start with the Exception: java.lang.UnsupportedOperationExcep

Re: Slack request

Would love an invite too please. On Fri, Jan 19, 2018 at 11:24 AM, Lukasz Cwik wrote: > Invite sent, welcome. > > On Fri, Jan 19, 2018 at 11:23 AM, Allan Wilson > wrote: > >> Can you add me as well? >> >> Allan Wilson >> Principal Software Engineer >> Pandora Media Inc >> >> Thanks >> >> From: