Hadoop fs mkdir 并使用 FileSystem.exists 进行测试

Question

我可以使用以下命令在我的 hadoop 中创建目录:hadoop fs -mkdir/test/input。我可以通过浏览 localhost:50070 来检查它，它有效:

/test
/tmp

但是当我从 java 检查是否存在时:

FileSystem fs = FileSystem.get(conf);
fs.exists(new Path("/tmp")); // returns true
fs.exists(new Path("/test")); // returns false

即使我在/tmp 中创建测试，也会发生同样的事情。怎么了？

谢谢，

Answer 1

FileSystem.get(conf) 可能会返回/tmp/ 文件夹存在而/test/ 不存在的本地文件系统。尝试指定要获取的文件系统:

FileSystem fs = new Path("hdfs://localhost:8020/").getFileSystem(conf);

我不确定端口，你可能需要 9000。