diff --git a/spark/v3.0/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteManifestsProcedure.java b/spark/v3.0/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteManifestsProcedure.java index 7ad33b675997..eae7ce0fca97 100644 --- a/spark/v3.0/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteManifestsProcedure.java +++ b/spark/v3.0/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteManifestsProcedure.java @@ -85,7 +85,7 @@ public InternalRow[] call(InternalRow args) { RewriteManifests action = actions().rewriteManifests(table); if (useCaching != null) { - action.option("use-caching", "true"); + action.option("use-caching", useCaching.toString()); } RewriteManifests.Result result = action.execute(); diff --git a/spark/v3.1/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteManifestsProcedure.java b/spark/v3.1/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteManifestsProcedure.java index 7ad33b675997..eae7ce0fca97 100644 --- a/spark/v3.1/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteManifestsProcedure.java +++ b/spark/v3.1/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteManifestsProcedure.java @@ -85,7 +85,7 @@ public InternalRow[] call(InternalRow args) { RewriteManifests action = actions().rewriteManifests(table); if (useCaching != null) { - action.option("use-caching", "true"); + action.option("use-caching", useCaching.toString()); } RewriteManifests.Result result = action.execute(); diff --git a/spark/v3.2/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteManifestsProcedure.java b/spark/v3.2/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteManifestsProcedure.java index 7ad33b675997..eae7ce0fca97 100644 --- a/spark/v3.2/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteManifestsProcedure.java +++ b/spark/v3.2/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteManifestsProcedure.java @@ -85,7 +85,7 @@ public InternalRow[] call(InternalRow args) { RewriteManifests action = actions().rewriteManifests(table); if (useCaching != null) { - action.option("use-caching", "true"); + action.option("use-caching", useCaching.toString()); } RewriteManifests.Result result = action.execute();