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