Jeffwan edited a comment on pull request #11311:
URL: https://github.com/apache/beam/pull/11311#issuecomment-672635327
@robertwb @ihji
I've seen issues in v2.22.0 related to this. Seems applications failed to
stage artifacts.
```
File
"/usr/local/lib/python3.7/site-packages/apache_beam/runners/portability/portable_runner.py",
line 426, in run_pipeline
job_service_handle.submit(proto_pipeline)
File
"/usr/local/lib/python3.7/site-packages/apache_beam/runners/portability/portable_runner.py",
line 111, in submit
prepare_response.staging_session_token)
File
"/usr/local/lib/python3.7/site-packages/apache_beam/runners/portability/portable_runner.py",
line 194, in stage
return self._stage_via_portable_service(channel, staging_session_token)
File
"/usr/local/lib/python3.7/site-packages/apache_beam/runners/portability/portable_runner.py",
line 212, in _stage_via_portable_service
staging_session_token)
File
"/usr/local/lib/python3.7/site-packages/apache_beam/runners/portability/artifact_service.py",
line 507, in offer_artifacts
for request in requests:
File "/usr/local/lib/python3.7/site-packages/grpc/_channel.py", line 388,
in __next__
return self._next()
File "/usr/local/lib/python3.7/site-packages/grpc/_channel.py", line 365,
in _next
raise self
grpc._channel._Rendezvous: <_Rendezvous of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "failed to connect to all addresses"
debug_error_string =
"{"created":"@1597212823.870639305","description":"Failed to pick
subchannel","file":"src/core/ext/filters/client_channel/client_channel.cc","file_line":3876,"referenced_errors":[{"created":"@1597212823.870635855","description":"failed
to connect to all
addresses","file":"src/core/ext/filters/client_channel/lb_policy/pick_first/pick_first.cc","file_line":395,"grpc_status":14}]}"
```
Is my job server setting misconfigured? How to leverage new API in job
server?
Here's my job server setting
```
- name: beam-job-server
image: apache/beam_flink1.10_job_server:2.22.0
imagePullPolicy: Always
args:
- "--flink-master=beam-flink-cluster-jobmanager:8081"
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
