You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by da...@apache.org on 2024/07/29 09:08:30 UTC
(hudi) branch master updated: [HUDI-8030] Fix for add missing table configurations to payloadProps (fixes #11685) (#11698)
This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new 00ebe1bf7aa [HUDI-8030] Fix for add missing table configurations to payloadProps (fixes #11685) (#11698)
00ebe1bf7aa is described below
commit 00ebe1bf7aa11bc9739372f9d5140164923a6d4d
Author: ailin zhou <al...@gmail.com>
AuthorDate: Mon Jul 29 17:08:24 2024 +0800
[HUDI-8030] Fix for add missing table configurations to payloadProps (fixes #11685) (#11698)
Co-authored-by: zhouailin <zh...@kuaishou.com>
---
.../org/apache/hudi/hadoop/realtime/AbstractRealtimeRecordReader.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/AbstractRealtimeRecordReader.java b/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/AbstractRealtimeRecordReader.java
index 058ca11a9a0..28f1218961f 100644
--- a/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/AbstractRealtimeRecordReader.java
+++ b/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/AbstractRealtimeRecordReader.java
@@ -88,6 +88,7 @@ public abstract class AbstractRealtimeRecordReader {
try {
metaClient = HoodieTableMetaClient.builder()
.setConf(HadoopFSUtils.getStorageConfWithCopy(jobConf)).setBasePath(split.getBasePath()).build();
+ payloadProps.putAll(metaClient.getTableConfig().getProps(true));
if (metaClient.getTableConfig().getPreCombineField() != null) {
this.payloadProps.setProperty(HoodiePayloadProps.PAYLOAD_ORDERING_FIELD_PROP_KEY, metaClient.getTableConfig().getPreCombineField());
}