diff --git a/hudi-hive/src/main/java/org/apache/hudi/hive/util/SchemaUtil.java b/hudi-hive/src/main/java/org/apache/hudi/hive/util/SchemaUtil.java index 6cd7747a6..289f2f70e 100644 --- a/hudi-hive/src/main/java/org/apache/hudi/hive/util/SchemaUtil.java +++ b/hudi-hive/src/main/java/org/apache/hudi/hive/util/SchemaUtil.java @@ -410,7 +410,7 @@ public class SchemaUtil { List partitionFields = new ArrayList<>(); for (String partitionKey : config.partitionFields) { String partitionKeyWithTicks = tickSurround(partitionKey); - partitionFields.add(new StringBuilder().append(partitionKey).append(" ") + partitionFields.add(new StringBuilder().append(partitionKeyWithTicks).append(" ") .append(getPartitionKeyType(hiveSchema, partitionKeyWithTicks)).toString()); }