CopyToRemote return error: 'proto: cannot parse invalid wire-format data'

[baiweiguo]

when I use CopyToRemote method，return error: 'copy err: proto: cannot parse invalid wire-format data', whereas copytoremote.txt is created ok in hadoop, but it has no content, I have no idea what's wrong.

here is my code:

package main

import (
        "fmt"
        "os"

        "github.com/colinmarc/hdfs/v2"
)

func main() {
        options := hdfs.ClientOptions{
                Addresses: []string{"127.0.0.1:9000"},
                User:      "hadoop",
        }
        client, err := hdfs.NewClient(options)
        if err != nil {
                fmt.Println("new err:", err)
                return
        }

        var mode = 0777 | os.ModeDir
        err = client.MkdirAll("/_test", mode)
        if err != nil {
                fmt.Println("mk err:", err)
                return
        }

        err = client.CopyToRemote("./testdata/mobydick.txt", "/_test/copytoremote.txt")
        if err != nil {
                fmt.Println("cp err:", err)
                return
        }
        fmt.Println("ok")
}