[
https://issues.apache.org/jira/browse/BEAM-9577?focusedWorklogId=469533&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-469533
]
ASF GitHub Bot logged work on BEAM-9577:
----------------------------------------
Author: ASF GitHub Bot
Created on: 12/Aug/20 06:33
Start Date: 12/Aug/20 06:33
Worklog Time Spent: 10m
Work Description: 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]
Issue Time Tracking
-------------------
Worklog Id: (was: 469533)
Time Spent: 28.5h (was: 28h 20m)
> Update artifact staging and retrieval protocols to be dependency aware.
> -----------------------------------------------------------------------
>
> Key: BEAM-9577
> URL: https://issues.apache.org/jira/browse/BEAM-9577
> Project: Beam
> Issue Type: Improvement
> Components: beam-model
> Reporter: Robert Bradshaw
> Priority: P2
> Time Spent: 28.5h
> Remaining Estimate: 0h
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
