Re: Flink job cannot find recover path after using entropy injection for s3 file systems

[chenqin]

make it easier to read

        @Nullable
        private static EntropyInjectingFileSystem getEntropyFs(FileSystem fs) {
                LOG.warn(fs.getClass().toGenericString());
                if (fs instanceof EntropyInjectingFileSystem) {
                        return (EntropyInjectingFileSystem) fs;
                } else if (fs instanceof SafetyNetWrapperFileSystem) {
                        FileSystem delegate = ((SafetyNetWrapperFileSystem)
fs).getWrappedDelegate();
                        return getEntropyFs(delegate);
                } else if (fs instanceof
PluginFileSystemFactory.ClassLoaderFixingFileSystem) {
                        FileSystem innerFs =
((PluginFileSystemFactory.ClassLoaderFixingFileSystem) fs).getInner();
                        return getEntropyFs(innerFs);
                }
                else {
                        return null;
                }
        }



--
Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/