diff --git a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/codec/SnappyCompressor.java b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/codec/SnappyCompressor.java index f09989634a..d0270ca7c1 100644 --- a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/codec/SnappyCompressor.java +++ b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/codec/SnappyCompressor.java @@ -113,7 +113,7 @@ public void end() { } @Override - public void finish() { + public synchronized void finish() { finishCalled = true; } diff --git a/pom.xml b/pom.xml index f606faaad4..dcc403dff7 100644 --- a/pom.xml +++ b/pom.xml @@ -244,6 +244,7 @@ org/apache/parquet/avro/SpecificDataSupplier org/apache/parquet/io/ColumnIOFactory$ColumnIOCreatorVisitor org/apache/parquet/io/ColumnIOFactory/** + org/apache/parquet/hadoop/codec/SnappyCompressor