You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "konwu (Jira)" <ji...@apache.org> on 2020/05/08 07:44:00 UTC

[jira] [Created] (FLINK-17569) to support ViewFileSystem when wait lease revoke of hadoop filesystem

konwu created FLINK-17569:
-----------------------------

             Summary: to support ViewFileSystem when wait lease revoke of hadoop filesystem
                 Key: FLINK-17569
                 URL: https://issues.apache.org/jira/browse/FLINK-17569
             Project: Flink
          Issue Type: Bug
          Components: FileSystems
            Reporter: konwu


Currently waitUntilLeaseIsRevoked method is not support ViewFileSystem and it will case the same issue [fail to recover after taskmanager failure|https://issues.apache.org/jira/browse/FLINK-11419]

 

 

I try to resolve the real path and FileSystem of ViewFileSystem  and it works
{code:java}
if (fs instanceof ViewFileSystem) {
   ViewFileSystem vfs = (ViewFileSystem) fs;
   Path resolvePath = vfs.resolvePath(path);
   DistributedFileSystem dfs = (DistributedFileSystem) resolvePath.getFileSystem(fs.getConf());
   return waitUntilLeaseIsRevoked(dfs, resolvePath);
}
{code}
 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)