diff --git a/pyiceberg/io/pyarrow.py b/pyiceberg/io/pyarrow.py index acfa9c0729..f7c0aef68c 100644 --- a/pyiceberg/io/pyarrow.py +++ b/pyiceberg/io/pyarrow.py @@ -1775,7 +1775,7 @@ def _get_int(key: str) -> Optional[int]: if unsupported_keys := fnmatch.filter(table_properties, key_pattern): raise NotImplementedError(f"Parquet writer option(s) {unsupported_keys} not implemented") - compression_codec = table_properties.get("write.parquet.compression-codec") + compression_codec = table_properties.get("write.parquet.compression-codec", "zstd") compression_level = _get_int("write.parquet.compression-level") if compression_codec == "uncompressed": compression_codec = "none" diff --git a/tests/integration/test_writes.py b/tests/integration/test_writes.py index 327e539c82..a65d98fc9e 100644 --- a/tests/integration/test_writes.py +++ b/tests/integration/test_writes.py @@ -458,7 +458,6 @@ def test_write_parquet_compression_properties( assert compression == expected_compression_name -@pytest.mark.integration @pytest.mark.integration @pytest.mark.parametrize( "properties, expected_kwargs", @@ -487,8 +486,6 @@ def test_write_parquet_other_properties( assert call_kwargs.get(key) == value -@pytest.mark.integration -@pytest.mark.integration @pytest.mark.integration @pytest.mark.parametrize( "properties",