From b1446be2b4d50e60b54146c66a6e6412d41b3a17 Mon Sep 17 00:00:00 2001 From: Vinoth Chandar Date: Wed, 11 Sep 2019 15:47:22 -0700 Subject: [PATCH] [HUDI-244] : Hive sync should escape partition field name - now supports field names beginning with '_' for e.g --- .../src/main/java/org/apache/hudi/hive/util/SchemaUtil.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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()); }