You are viewing a plain text version of this content. The canonical link for it is here.
Posted to github@beam.apache.org by GitBox <gi...@apache.org> on 2020/08/12 06:25:38 UTC
[GitHub] [beam] Jeffwan commented on pull request #11311: [BEAM-9577] Attempt to stage resources via new API in portable runner.
Jeffwan commented 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.
```
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?
----------------------------------------------------------------
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:
users@infra.apache.org