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..1c9282e173 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 @@ -50,8 +50,9 @@ public void write(byte[] b, int off, int len) throws IOException { wrapped.write(b, off, len); } + @Deprecated public void sync() throws IOException { - wrapped.hsync(); + // sync is not necessary for Parquet use cases. } @Override @@ -61,8 +62,6 @@ public void flush() throws IOException { @Override public void close() throws IOException { - try (FSDataOutputStream fdos = wrapped) { - fdos.hflush(); - } + wrapped.close(); } }