无法从java应用程序访问hdfs

ppcbkaq5  于 2021-05-31  发布在  Hadoop
关注(0)|答案(0)|浏览(314)

我有一个clouderquickstart容器,我尝试使用java应用程序获取hdfs下的文件列表;

  1. import org.apache.hadoop.conf.Configuration;
  2. import org.apache.hadoop.fs.FileStatus;
  3. import org.apache.hadoop.fs.FileSystem;
  4. import org.apache.hadoop.fs.Path;
  5. import org.apache.log4j.BasicConfigurator;
  6. import java.io.IOException;
  7. public class HdfsListing {
  8. public static void main(String[] args) throws IOException {
  9. BasicConfigurator.configure();
  10. Configuration configuration=new Configuration();
  11. configuration.set("fs.default.name","hdfs://172.17.0.2:9000");
  12. FileSystem fs=FileSystem.get(configuration);
  13. Path path=new Path("hdfs://172.17.0.2:9000/user");
  14. FileStatus[] fsl=fs.listStatus(path);
  15. for(FileStatus f:fsl) System.out.println("=======>"+f.getPath().getName());
  16. }
  17. }

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

  1. 7790 [main] DEBUG org.apache.hadoop.ipc.Client - The ping interval is 60000 ms.
  2. 7792 [main] DEBUG org.apache.hadoop.ipc.Client - Connecting to /172.17.0.2:9000
  3. 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
  4. ...

hadoop下的hosts文件

  1. # 127.0.0.1 localhost
  2. # ::1 localhost ip6-localhost ip6-loopback
  3. # fe00::0 ip6-localnet
  4. # ff00::0 ip6-mcastprefix
  5. # ff02::1 ip6-allnodes
  6. # ff02::2 ip6-allrouters
  7. 172.17.0.2 quickstart.cloudera quickstart

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题