[MINOR] Add backtick escape while syncing partition fields (#967)
This commit is contained in:
committed by
vinoth chandar
parent
14dd649d06
commit
4529f535b2
@@ -179,7 +179,7 @@ public class HoodieHiveClient {
|
|||||||
+ ". Check partition strategy. ");
|
+ ". Check partition strategy. ");
|
||||||
List<String> partBuilder = new ArrayList<>();
|
List<String> partBuilder = new ArrayList<>();
|
||||||
for (int i = 0; i < syncConfig.partitionFields.size(); i++) {
|
for (int i = 0; i < syncConfig.partitionFields.size(); i++) {
|
||||||
partBuilder.add(syncConfig.partitionFields.get(i) + "=" + "'" + partitionValues.get(i) + "'");
|
partBuilder.add("`" + syncConfig.partitionFields.get(i) + "`=" + "'" + partitionValues.get(i) + "'");
|
||||||
}
|
}
|
||||||
return partBuilder.stream().collect(Collectors.joining(","));
|
return partBuilder.stream().collect(Collectors.joining(","));
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user