Hi,
can you please share the command-line and complete output of the script?
Are you using minikube? Can you share list of your running pods?
Jan
On 1/30/23 14:25, P Singh wrote:
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.
