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: [email protected] With regards, Apache Git Services
