package main
import (
"fmt"
"github.com/colinmarc/hdfs"
)
func main() {
client, err := hdfs.New("192.168.0.38:50070")
fs, err := client.ReadDir("/")
fmt.Println(err)
fmt.Println(fs)
}
err 是意外的 EOF 而且我发现错误发生在
func (c *NamenodeConnection) readResponse(method string, resp proto.Message) error {
...
_, err = io.ReadFull(c.conn, packet)
...
}
我正在使用 hadoop 2.7.3
请您参考如下方法:
我找到了原因。我使用的是 WEBHDFS 端口 (50070) 而不是 Hadoop IPC 端口 (9000)。