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)。


评论关闭
IT虾米网

微信公众号号:IT虾米 (左侧二维码扫一扫)欢迎添加!