diff --git a/paimon-format/src/main/java/org/apache/paimon/format/parquet/writer/RowDataParquetBuilder.java b/paimon-format/src/main/java/org/apache/paimon/format/parquet/writer/RowDataParquetBuilder.java index 5e2f8550f3e6..26d38a1c1863 100644 --- a/paimon-format/src/main/java/org/apache/paimon/format/parquet/writer/RowDataParquetBuilder.java +++ b/paimon-format/src/main/java/org/apache/paimon/format/parquet/writer/RowDataParquetBuilder.java @@ -76,9 +76,6 @@ public ParquetWriter createWriter(OutputFile out, String compressio } public String getCompression(String compression) { - if (conf.get("parquet.compression") != null) { - return conf.get("parquet.compression"); - } - return compression; + return conf.get("parquet.compression", compression); } }