Hi Team, I am trying to run beam job on top of flink on my local machine (kubernetes).
I have flink 1.14 and beam 2.43 images both running but when i submit the job it's not reaching to the flink cluster and getting failed with below error. ERROR:apache_beam.utils.subprocess_server:Starting job service with ['java', '-jar', '/Users/spsingh/.apache_beam/cache/jars/beam-runners-flink-1.14-job-server-2.43.0.jar', '--flink-master', 'http://localhost:8081', '--artifacts-dir', '/var/folders/n3/dqblsr792yj4kfs7xlfmdj540000gr/T/beam-tempvphhje07/artifacts6kjt60ch', '--job-port', '57882', '--artifact-port', '0', '--expansion-port', '0'] ERROR:apache_beam.utils.subprocess_server:Error bringing up service Traceback (most recent call last): File "/Users/flink_deploy/flink_env/lib/python3.10/site-packages/apache_beam/utils/subprocess_server.py", line 88, in start raise RuntimeError( RuntimeError: Service failed to start up with error 1 Any help would be appreciated.
