, the python pipeline works on beam but not if I want to
submit on flink via PortableRunner or FlinkRunner.
Thanks.
From: Maximilian Michels
Sent: Thursday, May 28, 2020, 5:34 PM
To: user@beam.apache.org
Subject: Re: Issue while submitting python beam pipeline on flink
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
Sent: 28 May 2020 17:34
To: user@beam.apache.org
Subject: Re: Issue while submitting python beam pipeline
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.
>
>
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",
