Hello Guys , I am trying to run a python beam pipeline on flink. I am trying to run apache_beam.examples.wordcount_minimal but with Pipelineoptions as "--runner=PortableRunner", "--job_endpoint=192.168.99.100:8099", "--environment_type=LOOPBACK",
I have a apachebeam/flink1.9_job_server running on local container. Whenever I submit the job , I get errors ( attached the log).When I run it with DirectRunner, the code runs fine though. versions: Apache Beam SDK=2.21.0 python=3.7.6 I have followed all instruction from the apache beam UI but I seem to have hit a roadblock here. Please suggest. Please let me know if any other information is required. Ashish Raghav | DE Core Compete<https://corecompete.com/> | [email protected]<mailto:[email protected]> Accelerating Cloud Analytics [cid:[email protected]][cid:[email protected]]
log
Description: log
