diff --git a/pkg/load/batch_loader.go b/pkg/load/batch_loader.go
index 908d59b..1d4a1ce 100644
--- a/pkg/load/batch_loader.go
+++ b/pkg/load/batch_loader.go
@@ -88,7 +88,7 @@ func (b *CSVBatchLoader) InsertValue(ctx context.Context, columns []string) erro
 // Flush inserts all pending values
 func (b *CSVBatchLoader) Flush(ctx context.Context) error {
 	b.writer.Flush()
-	return nil
+	return b.writer.Error()
 }
 
 // Close closes the file.