loss fileID cause write failed

file_writer.go

@@ -27,6 +27,7 @@ type FileWriter struct {
 	name        string
 	replication int
 	blockSize   int64
+	fileId      *uint64
 
 	blockWriter *transfer.BlockWriter
 	deadline    time.Time
@@ -82,6 +83,7 @@ func (c *Client) CreateFile(name string, replication int, blockSize int64, perm
 		name:        name,
 		replication: replication,
 		blockSize:   blockSize,
+		fileId:      createResp.Fs.FileId,
 	}, nil
 }
 
@@ -111,6 +113,7 @@ func (c *Client) Append(name string) (*FileWriter, error) {
 		name:        name,
 		replication: int(appendResp.Stat.GetBlockReplication()),
 		blockSize:   int64(appendResp.Stat.GetBlocksize()),
+		fileId:      appendResp.Stat.FileId,
 	}
 
 	// This returns nil if there are no blocks (it's an empty file) or if the
@@ -233,23 +236,15 @@ func (f *FileWriter) Close() error {
 		}
 	}
 
-	getFileInfoReq := &hdfs.GetFileInfoRequestProto{Src: proto.String(f.name)}
-	getFileInfoResp := &hdfs.GetFileInfoResponseProto{}
-
-	err := f.client.namenode.Execute("getFileInfo", getFileInfoReq, getFileInfoResp)
-	if err != nil {
-		return &os.PathError{"getFileInfo", f.name, err}
-	}
-
 	completeReq := &hdfs.CompleteRequestProto{
 		Src:        proto.String(f.name),
 		ClientName: proto.String(f.client.namenode.ClientName),
 		Last:       lastBlock,
-		FileId:     getFileInfoResp.Fs.FileId,
+		FileId:     f.fileId,
 	}
 	completeResp := &hdfs.CompleteResponseProto{}
 
-	err = f.client.namenode.Execute("complete", completeReq, completeResp)
+	err := f.client.namenode.Execute("complete", completeReq, completeResp)
 	if err != nil {
 		return &os.PathError{"create", f.name, err}
 	} else if completeResp.GetResult() == false {
@@ -276,6 +271,7 @@ func (f *FileWriter) startNewBlock() error {
 		Src:        proto.String(f.name),
 		ClientName: proto.String(f.client.namenode.ClientName),
 		Previous:   previous,
+		FileId:     f.fileId,
 	}
 	addBlockResp := &hdfs.AddBlockResponseProto{}