|
@@ -435,7 +435,7 @@ public class DistributedCache {
|
|
@Deprecated
|
|
@Deprecated
|
|
public static void addFileToClassPath(Path file, Configuration conf)
|
|
public static void addFileToClassPath(Path file, Configuration conf)
|
|
throws IOException {
|
|
throws IOException {
|
|
- addFileToClassPath(file, conf, FileSystem.get(conf));
|
|
|
|
|
|
+ addFileToClassPath(file, conf, file.getFileSystem(conf));
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -495,7 +495,7 @@ public class DistributedCache {
|
|
public static void addArchiveToClassPath
|
|
public static void addArchiveToClassPath
|
|
(Path archive, Configuration conf)
|
|
(Path archive, Configuration conf)
|
|
throws IOException {
|
|
throws IOException {
|
|
- addArchiveToClassPath(archive, conf, FileSystem.get(conf));
|
|
|
|
|
|
+ addArchiveToClassPath(archive, conf, archive.getFileSystem(conf));
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|