Hi Team, I am trying to run apache beam pipeline on flink cluster. I have set up kubernetes locally with flink1.16and apache/beam_python3.10_sdk:2.44.0. When I submit the job using like
python file.py Job is just hang not able to see on flink UI or logs. Can you please suggest compatible versions? Looking forward to hearing from you.
