无法从Java应用程序访问HDFS

我有一个clouder快速入门容器,我尝试使用Java应用程序获取HDFS下的文件列表;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.log4j.BasicConfigurator;

import java.io.IOException;

public class HdfsListing {
    public static void main(String[] args) throws IOException {
        BasicConfigurator.configure();
        Configuration  configuration=new Configuration();
        configuration.set("fs.default.name","hdfs://172.17.0.2:9000");

        FileSystem fs=FileSystem.get(configuration);
        Path path=new Path("hdfs://172.17.0.2:9000/user");
        FileStatus[] fsl=fs.listStatus(path);
        for(FileStatus f:fsl) System.out.println("=======>"+f.getPath().getName());
    }
}

运行该代码时,我在控制台中收到以下消息

7790 [main] DEBUG org.apache.hadoop.ipc.Client  - The ping interval is 60000 ms.
7792 [main] DEBUG org.apache.hadoop.ipc.Client  - Connecting to /172.17.0.2:9000
32439 [main] INFO org.apache.hadoop.ipc.Client  - retrying connect to server: 172.17.0.2/172.17.0.2:9000. Already tried 0 time(s); maxRetries=45
...

hadoop下的主机文件

#127.0.0.1      localhost
#::1    localhost ip6-localhost ip6-loopback
#fe00::0        ip6-localnet
#ff00::0        ip6-mcastprefix
#ff02::1        ip6-allnodes
#ff02::2        ip6-allrouters
172.17.0.2      quickstart.cloudera quickstart
nishiwoderena222 回答:无法从Java应用程序访问HDFS

暂时没有好的解决方案,如果你有好的解决方案,请发邮件至:iooj@foxmail.com
本文链接:https://www.f2er.com/2418188.html

大家都在问