diff --git a/lib/writer.js b/lib/writer.js
index f1130e81..2d66d65a 100644
--- a/lib/writer.js
+++ b/lib/writer.js
@@ -271,7 +271,7 @@ class ParquetTransformer extends stream.Transform {
   }
 
   _flush(callback) {
-    this.writer.close(callback);
+    this.writer.close(callback).catch((er) => {callback(er)});
   }
 
 }