zendesk-kjaanson commented on issue #32743:
URL: https://github.com/apache/beam/issues/32743#issuecomment-2706068633

   How should the artefact staging to workers work? Not through shared staging 
directory?
   
   I am wondering if me getting the staging volume sharing working might simply 
have sidestepped the actual issue?
   
   When I am looking staging folder in jobmanager and taskmanagers then 
jobmanager staging looks like this
   `/tmp/beam-artifact-staging/<flink job id>`
   
   ```
   -rw-r--r-- 1 root root 126850563 Mar  7 09:39 
1-0:ref_Environment_default-workflow.tar.gz
   -rw-r--r-- 1 root root      7406 Mar  7 09:39 
2-0:ref_Environment_default-pickled_main_session
   -rw-r--r-- 1 root root      3257 Mar  7 09:39 
3-0:ref_Environment_default-submission_environment_dependencies.txt
   ```
   
   However taskmanager logs show that ArtefactRetrievalService is not able to 
fetch anything unless the staging volume is actually shared between jobmanager 
and taskmanagers. This error is in task managers logs
   
   ```
   java.io.FileNotFoundException: /tmp/beam-artifact-staging/<flink job 
id>/3-0:ref_Environment_default-submission_environment_dependencies.txt (No 
such file or directory)
   ```
   


-- 
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.

To unsubscribe, e-mail: github-unsubscr...@beam.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to