From 03d0df0cd4df8d69416c53a292775cf5515ae92d Mon Sep 17 00:00:00 2001 From: Yuya Ebihara Date: Sun, 16 Feb 2025 10:51:34 +0900 Subject: [PATCH] Spark 3.5: Fix job description of RewriteTablePathSparkAction --- .../iceberg/spark/actions/RewriteTablePathSparkAction.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteTablePathSparkAction.java b/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteTablePathSparkAction.java index c9382fafd8ae..4c9e5c5e4a96 100644 --- a/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteTablePathSparkAction.java +++ b/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteTablePathSparkAction.java @@ -239,7 +239,7 @@ private boolean versionInFilePath(String path, String version) { } private String jobDesc() { - if (startVersionName != null) { + if (startVersionName == null) { return String.format( "Replacing path prefixes '%s' with '%s' in the metadata files of table %s," + "up to version '%s'.",