From d2cda00cfa9601ad2471ed024ed6d687b70c8d2f Mon Sep 17 00:00:00 2001 From: sivabalan Date: Wed, 23 Mar 2022 01:51:29 -0700 Subject: [PATCH] Fixing non partitioned all files record in MDT --- .../java/org/apache/hudi/metadata/HoodieMetadataPayload.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataPayload.java b/hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataPayload.java index f7d45db8b9a3f..8680a8c83662f 100644 --- a/hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataPayload.java +++ b/hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataPayload.java @@ -59,6 +59,7 @@ import static org.apache.hudi.common.util.ValidationUtils.checkArgument; import static org.apache.hudi.common.util.ValidationUtils.checkState; import static org.apache.hudi.metadata.HoodieTableMetadata.RECORDKEY_PARTITION_LIST; +import static org.apache.hudi.metadata.HoodieTableMetadataUtil.getPartition; /** * MetadataTable records are persisted with the schema defined in HoodieMetadata.avsc. @@ -222,7 +223,7 @@ protected HoodieMetadataPayload(String key, int type, */ public static HoodieRecord createPartitionListRecord(List partitions) { Map fileInfo = new HashMap<>(); - partitions.forEach(partition -> fileInfo.put(partition, new HoodieMetadataFileInfo(0L, false))); + partitions.forEach(partition -> fileInfo.put(getPartition(partition), new HoodieMetadataFileInfo(0L, false))); HoodieKey key = new HoodieKey(RECORDKEY_PARTITION_LIST, MetadataPartitionType.FILES.getPartitionPath()); HoodieMetadataPayload payload = new HoodieMetadataPayload(key.getRecordKey(), METADATA_TYPE_PARTITION_LIST,