[iceberg] branch master updated: Spark: Fix spacing in warn log in ExpireSnapshotsProcedure (#8578)

[etudenhoefner]

This is an automated email from the ASF dual-hosted git repository.

etudenhoefner pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git


The following commit(s) were added to refs/heads/master by this push:
     new d6bc248adb Spark: Fix spacing in warn log in ExpireSnapshotsProcedure 
(#8578)
d6bc248adb is described below

commit d6bc248adb67de74e31dcb9c0af43fef68853d59
Author: Amogh Jahagirdar <am...@tabular.io>
AuthorDate: Sun Sep 17 23:11:30 2023 -0700

    Spark: Fix spacing in warn log in ExpireSnapshotsProcedure (#8578)
---
 .../org/apache/iceberg/spark/procedures/ExpireSnapshotsProcedure.java   | 2 +-
 .../org/apache/iceberg/spark/procedures/ExpireSnapshotsProcedure.java   | 2 +-
 .../org/apache/iceberg/spark/procedures/ExpireSnapshotsProcedure.java   | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

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 9d2fc7e467..b84d69ea9c 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 class ExpireSnapshotsProcedure extends BaseProcedure 
{
           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 9d2fc7e467..b84d69ea9c 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 class ExpireSnapshotsProcedure extends BaseProcedure 
{
           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 9d2fc7e467..b84d69ea9c 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 class ExpireSnapshotsProcedure extends BaseProcedure 
{
           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.",