panic: mkdir /demo: read tcp 192.168.10.1:57318->192.168.10.102:9870: wsarecv: An established connection was aborted by the software in your host machine.

[withoutabc]

package main

import (
"fmt"
"github.com/colinmarc/hdfs/v2"
"log"
)

var (
HDFSADDR = "hadoop102:9870"
User = "root"
)

func main() {
// 创建一个HDFS客户端配置
options := hdfs.ClientOptions{
Addresses: []string{HDFSADDR},
User: User,
}
client, err := hdfs.NewClient(options)
if err != nil {
panic(err)
}
log.Println(client)
// 创建一个目录，如果目录已存在则无操作
err = client.Mkdir("/demo", 0777)
if err != nil {
panic(err)
}
fmt.Println("目录创建成功")
}
When I want to mkdir, it shows "panic: mkdir /demo: read tcp 192.168.10.1:57318->192.168.10.102:9870: wsarecv: An established connection was aborted by the software in your host machine."

How can I deal with it?