diff --git a/lib/writer.js b/lib/writer.js index 130d328e..056b3a4c 100644 --- a/lib/writer.js +++ b/lib/writer.js @@ -313,7 +313,7 @@ class ParquetTransformer extends stream.Transform { } _flush(callback) { - this.writer.close(callback) + this.writer.close() .then(d => callback(null, d), callback); }