diff --git a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/rewrite/RewriteOptions.java b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/rewrite/RewriteOptions.java index 0dc76b8a2a..a2a1c18e32 100644 --- a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/rewrite/RewriteOptions.java +++ b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/rewrite/RewriteOptions.java @@ -21,11 +21,11 @@ import java.util.ArrayList; import java.util.Collections; import java.util.HashMap; +import java.util.HashSet; import java.util.List; import java.util.Map; import java.util.Set; import java.util.stream.Collectors; -import org.apache.curator.shaded.com.google.common.collect.ImmutableSet; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.Path; import org.apache.parquet.Preconditions; @@ -617,7 +617,7 @@ private void checkPreconditions() { if (renameColumns != null) { Set nullifiedColumns = maskColumns == null - ? ImmutableSet.of() + ? new HashSet<>() : maskColumns.entrySet().stream() .filter(x -> x.getValue() == MaskMode.NULLIFY) .map(Map.Entry::getKey)