[GitHub] [flink] HuangZhenQiu commented on issue #9711: [FLINK-14033][yarn] upload user artifacts for yarn job cluster

[GitBox <gi...@apache.org>]

HuangZhenQiu commented on issue #9711: [FLINK-14033][yarn] upload user artifacts for yarn job cluster
URL: https://github.com/apache/flink/pull/9711#issuecomment-559370853
 
 
   @aljoscha Thanks for pointing out issues in test case. I rebased latest master and removed unused classes. The distributed cache functionality should be covered in the map function.  For the life cycle of the distributed cache files, we should split into two parts. For the local copies in each TM, they are managed as a rolling array in the FileCache class. Any time one acces to a file not in FileCache, the file will be read from remote. For the remote file, it is the same as other local resources files for yarn application, they are under the ./flink/application_id fodler. If user kill the job, the folder will be deleted. 

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


With regards,
Apache Git Services