Exception in thread "main" java.lang.IllegalArgumentException: Wrong FS: file:/path/to/my.jar, expected: hdfs://ec2-xx-xx-xx-xxx.compute-1.amazonaws.com
,如果我尝试将本地文件在Hadoop中添加分布式缓存。当文件在HDFS上时,我不会收到这个错误(显然,因为它使用了预期的FS)。有没有办法在分布式缓存中使用本地文件,而无需先将其复制到hdfs?下面的代码片段:
Configuration conf = job.getConfiguration();
FileSystem fs = FileSystem.getLocal(conf);
Path dependency = fs.makeQualified(new Path("/local/path/to/my.jar");
DistributedCache.addArchiveToClassPath(path, conf);
感谢