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());
       }