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