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)