diff --git a/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteManifestsSparkAction.java b/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteManifestsSparkAction.java index 475088b148c6..1425c3fcf8c9 100644 --- a/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteManifestsSparkAction.java +++ b/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteManifestsSparkAction.java @@ -317,7 +317,7 @@ private Column sortColumn() { // entry dataframe Column[] partitionColumns = partitionFieldClustering.stream() - .map(p -> col(DATA_FILE_PARTITION_COLUMN_NAME + "." + p)) + .map(p -> col(DATA_FILE_PARTITION_COLUMN_NAME + ".`" + p + "`")) .toArray(Column[]::new); // Form a new temporary column to cluster manifests on, based on the custom clustering columns diff --git a/spark/v4.0/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteManifestsSparkAction.java b/spark/v4.0/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteManifestsSparkAction.java index 668360c06730..666f9e9d5cb7 100644 --- a/spark/v4.0/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteManifestsSparkAction.java +++ b/spark/v4.0/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteManifestsSparkAction.java @@ -317,7 +317,7 @@ private Column sortColumn() { // entry dataframe Column[] partitionColumns = partitionFieldClustering.stream() - .map(p -> col(DATA_FILE_PARTITION_COLUMN_NAME + "." + p)) + .map(p -> col(DATA_FILE_PARTITION_COLUMN_NAME + ".`" + p + "`")) .toArray(Column[]::new); // Form a new temporary column to cluster manifests on, based on the custom clustering columns diff --git a/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteManifestsSparkAction.java b/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteManifestsSparkAction.java index 668360c06730..666f9e9d5cb7 100644 --- a/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteManifestsSparkAction.java +++ b/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteManifestsSparkAction.java @@ -317,7 +317,7 @@ private Column sortColumn() { // entry dataframe Column[] partitionColumns = partitionFieldClustering.stream() - .map(p -> col(DATA_FILE_PARTITION_COLUMN_NAME + "." + p)) + .map(p -> col(DATA_FILE_PARTITION_COLUMN_NAME + ".`" + p + "`")) .toArray(Column[]::new); // Form a new temporary column to cluster manifests on, based on the custom clustering columns