I can set that up. Can I test on linux? Ashish Raghav | DE Core Compete | ashish.rag...@corecompete.com Accelerating Cloud Analytics
-----Original Message----- From: Maximilian Michels <m...@apache.org> Sent: 28 May 2020 17:34 To: user@beam.apache.org Subject: Re: Issue while submitting python beam pipeline on flink cluster - local EXTERNAL EMAIL Do not click links or open attachments unless you recognise the sender and know the content is safe. Report suspicious email to info...@corecompete.com. Potentially a Windows issue. Do you have a Unix environment for testing? On 28.05.20 13:35, Ashish Raghav wrote: > Hi Guys, > > > > I have another issue when I submit the python beam pipeline ( > wordcount example provided by apache beam team) directly on flink > cluster running local. > > > > PipelineOptions are : > > "--runner=FlinkRunner", > > "--flink_version=1.9", > > "--environment_type=LOOPBACK", > > "--flink_master=192.168.99.100:8081", > > > > versions: > > Apache Beam SDK=2.21.0 > python=3.7.6 > > Flink=1.9.3 > > Please suggest , if I am missing something. > > > > *Ashish Raghav * > > >
