diff --git a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/util/HadoopPositionOutputStream.java b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/util/HadoopPositionOutputStream.java index df22e23772..6b7e0c10cb 100644 --- a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/util/HadoopPositionOutputStream.java +++ b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/util/HadoopPositionOutputStream.java @@ -62,7 +62,7 @@ public void flush() throws IOException { @Override public void close() throws IOException { try (FSDataOutputStream fdos = wrapped) { - fdos.hflush(); + fdos.flush(); } } }