xiarixiaoyao commented on a change in pull request #2716:
URL: https://github.com/apache/hudi/pull/2716#discussion_r617137325
##########
File path:
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/hive/HoodieCombineHiveInputFormat.java
##########
@@ -170,7 +170,7 @@ protected HoodieCombineFileInputFormatShim
createInputFormatShim() {
if (job.get(hive_metastoreConstants.META_TABLE_PARTITION_COLUMNS,
"").isEmpty()) {
List<String> partitions = new
ArrayList<>(part.getPartSpec().keySet());
if (!partitions.isEmpty()) {
- String partitionStr = String.join(",", partitions);
Review comment:
@nsivabalan just see the funtion initObjectInspector in
MapOperator.java(my hive version is hive 3.1.1):
// Next check if this table has partitions and if so
// get the list of partition names as well as allocate
// the serdes for the partition columns
**line 189** String pcols =
overlayedProps.getProperty(hive_metastoreConstants.META_TABLE_PARTITION_COLUMNS);
**line 191** if (pcols != null && pcols.length() > 0) {
**line 192** String[] partKeys = pcols.trim().split("/");
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]