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/> | ashish.rag...@corecompete.com<mailto:adwait.th...@corecompete.com> Accelerating Cloud Analytics [cid:image001.jpg@01D6350F.2C3D1330][cid:image002.png@01D6350F.2C3D1330]
log
Description: log
