append call failed with ERROR_APPLICATION (org.apache.hadoop.hdfs.protocol.AlreadyBeingCreatedException) about hdfs HOT 8 CLOSED

    nameServer := flag.String("nameserver", "", "The HDFS Name Node Address")
user := flag.String("user", "", "The HDFS Visitor User")
hdfsPath := flag.String("hdfsPath", "", "The HDFS  Which Will Write To HDFS")
createFlag := flag.String("create", "", "create file flag")
flag.Parse()
mockStr := fmt.Sprintf(time.Now().String())
client, err := hdfs.NewForUser(*nameServer, *user)
utee.Chk(err)
defer client.Close()
if *createFlag != "" {
	w, err := client.Create(*hdfsPath)
	if err != nil {
		log.Println("CreateFile err", err)
	}
	_, err = w.Write([]byte(mockStr))
	log.Println("write err", err)
	w.Close()
	return
}

w, err := client.Append(*hdfsPath)
//defer w.Close()
if err != nil {
	log.Println("append err", err)
	return
}
_, err = w.Write([]byte(mockStr))
log.Println("write err", err)
w.Close()

hdfl, err := hdcli.Append(path.Join(hfdsDir, name+".txt"))
if os.IsNotExist(err) {
	log.Println("File doesnot exist, creating...")
	err = hdcli.CreateEmptyFile(path.Join(hfdsDir, name+".jsonl"))
	if err != nil {
		log.Println("Error creating the file:", err)
	}
	hdfl, err = hdcli.Append(path.Join(hfdsDir, name+".jsonl"))
} else if err != nil {
	log.Println("Error opening the file with append:", err)
}
defer hdfl.Close()
hdg := json.NewEncoder(hdfl)
for{
    msg,err = con.Read()
    if err!=nil{
        return
    }
    hdg.Encode(msg)
    hdfl.Flush()
}