Java Hadoop 不完整的 HDFS URI，没有主机

Question

我正在尝试从 java 应用程序访问 hdfs，但出现错误 Incomplete HDFS URI, no host。

这是我的 core-site.xml

<configuration>
        <property>
                <name>fs.defaultFS</name>
                <value>hdfs://localhost:9000</value>
        </property>
</configuration>

这是我的 java 代码：

class AppTest {

    private static final String HDFS_PATH = "hdfs:localhost:9000";
    private static final String HDFS_USER = "hadoop";
    private static FileSystem fileSystem;
    @BeforeAll
    public static void prepare()
    {
        try {
            Configuration configuration = new Configuration();
            configuration.set("dfs.replication", "1");
            fileSystem = FileSystem.get(new URI(HDFS_PATH), configuration, HDFS_USER);
        } catch (IOException e) {
            e.printStackTrace();
        } catch(InterruptedException e){
            e.printStackTrace();
        } catch(URISyntaxException e){
            e.printStackTrace();
        }
    }
    @Test
    public void mkDir() throws Exception{
        fileSystem.mkdirs(new Path("/hdfs-api/test/"));
    }
    @AfterAll
    public static void destroy(){
        fileSystem = null;
    }
}

它总是抛出以下错误

java.io.IOException: Incomplete HDFS URI, no host: hdfs:localhost:9000

Answer 1

使用 netstat -tlpn | grep 9000 检查端口是否可用

将127.0.0.1替换为节点真实ip地址，示例：hdfs://192.168.10.1:9000

Java Hadoop 不完整的 HDFS URI，没有主机

Java Hadoop Incomplete HDFS URI, no host

java

hadoop

hdfs