From 20a0e66e71a472b9af973dd27e794b9261f8c676 Mon Sep 17 00:00:00 2001 From: ajantha-bhat Date: Sun, 8 May 2022 15:29:00 +0530 Subject: [PATCH] Spark: Fix unable to disable use-caching in RewriteManifestsProcedure --- .../iceberg/spark/procedures/RewriteManifestsProcedure.java | 2 +- .../iceberg/spark/procedures/RewriteManifestsProcedure.java | 2 +- .../iceberg/spark/procedures/RewriteManifestsProcedure.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) 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();