diff --git a/changeset/export.go b/changeset/export.go
index fb01b3a..39c3a84 100644
--- a/changeset/export.go
+++ b/changeset/export.go
@@ -165,7 +165,7 @@ func collectChunksToSegment(outputFile string, chunkFiles []string) error {
 		return err
 	}
 
-	return writer.Flush()
+	return bufWriter.Flush()
 }
 
 // copyTmpFile append the compressed temporary file to writer