[
https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786565#comment-17786565
]
zhengzhili commented on FLINK-33472:
------------------------------------
After creating the flink-conf.yaml temporary file in
YarnClusterDescriptor#startAppMaster, Through YarnApplicationFileUploader#
registerSingleLocalResource registered local files,
In this case, if (Utils.isRemotePath(resourcePath.toString())) is used to
determine whether the file is remote based on the path.
The incoming tmpConfigurationFile#getAbsolutePath makes Utils. IsRemotePath
considered remote file
When FileSystem is S3AFileSystem, the getFileStatus method displays an error
indicating that the file does not exist
Incoming parameters should be new Path (tmpConfigurationFile.toURI ()) to the
new Path (tmpConfigurationFile. getAbsolutePath ())
> Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem
> cannot be uploaded
> ------------------------------------------------------------------------------------------------
>
> Key: FLINK-33472
> URL: https://issues.apache.org/jira/browse/FLINK-33472
> Project: Flink
> Issue Type: Bug
> Components: Client / Job Submission
> Affects Versions: 1.17.1
> Reporter: zhengzhili
> Priority: Minor
> Attachments: image-2023-11-07-11-34-01-823.png,
> image-2023-11-07-11-34-29-548.png, image-2023-11-07-13-46-58-907.png
>
>
> Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem
> cannot be uploaded。
> !image-2023-11-07-11-34-29-548.png|width=595,height=175!
> !image-2023-11-07-13-46-58-907.png|width=635,height=179!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
