diff --git a/spark/v3.2/spark/src/main/java/org/apache/iceberg/spark/procedures/ExpireSnapshotsProcedure.java b/spark/v3.2/spark/src/main/java/org/apache/iceberg/spark/procedures/ExpireSnapshotsProcedure.java index 9d2fc7e467cf..b84d69ea9c1d 100644 --- a/spark/v3.2/spark/src/main/java/org/apache/iceberg/spark/procedures/ExpireSnapshotsProcedure.java +++ b/spark/v3.2/spark/src/main/java/org/apache/iceberg/spark/procedures/ExpireSnapshotsProcedure.java @@ -126,7 +126,7 @@ public InternalRow[] call(InternalRow args) { if (maxConcurrentDeletes != null) { if (table.io() instanceof SupportsBulkOperations) { LOG.warn( - "max_concurrent_deletes only works with FileIOs that do not support bulk deletes. This" + "max_concurrent_deletes only works with FileIOs that do not support bulk deletes. This " + "table is currently using {} which supports bulk deletes so the parameter will be ignored. " + "See that IO's documentation to learn how to adjust parallelism for that particular " + "IO's bulk delete.", diff --git a/spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/procedures/ExpireSnapshotsProcedure.java b/spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/procedures/ExpireSnapshotsProcedure.java index 9d2fc7e467cf..b84d69ea9c1d 100644 --- a/spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/procedures/ExpireSnapshotsProcedure.java +++ b/spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/procedures/ExpireSnapshotsProcedure.java @@ -126,7 +126,7 @@ public InternalRow[] call(InternalRow args) { if (maxConcurrentDeletes != null) { if (table.io() instanceof SupportsBulkOperations) { LOG.warn( - "max_concurrent_deletes only works with FileIOs that do not support bulk deletes. This" + "max_concurrent_deletes only works with FileIOs that do not support bulk deletes. This " + "table is currently using {} which supports bulk deletes so the parameter will be ignored. " + "See that IO's documentation to learn how to adjust parallelism for that particular " + "IO's bulk delete.", diff --git a/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/ExpireSnapshotsProcedure.java b/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/ExpireSnapshotsProcedure.java index 9d2fc7e467cf..b84d69ea9c1d 100644 --- a/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/ExpireSnapshotsProcedure.java +++ b/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/ExpireSnapshotsProcedure.java @@ -126,7 +126,7 @@ public InternalRow[] call(InternalRow args) { if (maxConcurrentDeletes != null) { if (table.io() instanceof SupportsBulkOperations) { LOG.warn( - "max_concurrent_deletes only works with FileIOs that do not support bulk deletes. This" + "max_concurrent_deletes only works with FileIOs that do not support bulk deletes. This " + "table is currently using {} which supports bulk deletes so the parameter will be ignored. " + "See that IO's documentation to learn how to adjust parallelism for that particular " + "IO's bulk delete.",