diff --git a/sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/RecordWriter.java b/sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/RecordWriter.java index 0b32274d2495..d606b406bd21 100644 --- a/sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/RecordWriter.java +++ b/sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/RecordWriter.java @@ -112,7 +112,7 @@ class RecordWriter { throw new RuntimeException("Unknown File Format: " + fileFormat); } activeIcebergWriters.inc(); - LOG.info( + LOG.debug( "Opened {} writer for table '{}', partition {}. Writing to path: {}", fileFormat, table.name(), @@ -137,7 +137,7 @@ public void close() throws IOException { } activeIcebergWriters.dec(); DataFile dataFile = icebergDataWriter.toDataFile(); - LOG.info( + LOG.debug( "Closed {} writer for table '{}' ({} records, {} bytes), path: {}", fileFormat, table.name(),