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 <[email protected]>
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 <[email protected]>
---
 .../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());
       }

Reply via email to