From cbc895cad98270ed92f0e0c810c77ab7cb68d63b Mon Sep 17 00:00:00 2001 From: alberic Date: Tue, 1 Nov 2022 15:20:11 +0800 Subject: [PATCH] [MINOR] Fix OverwriteWithLatestAvroPayload full class name (#7096) --- .../hudi/hadoop/realtime/AbstractRealtimeRecordReader.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 dfdda9dfc8259..ea71de07ba00b 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 @@ -20,6 +20,7 @@ import org.apache.hudi.common.model.HoodieAvroPayload; import org.apache.hudi.common.model.HoodiePayloadProps; +import org.apache.hudi.common.model.OverwriteWithLatestAvroPayload; import org.apache.hudi.common.table.HoodieTableMetaClient; import org.apache.hudi.exception.HoodieException; import org.apache.hudi.common.table.TableSchemaResolver; @@ -77,7 +78,7 @@ public AbstractRealtimeRecordReader(RealtimeSplit split, JobConf job) { private boolean usesCustomPayload(HoodieTableMetaClient metaClient) { return !(metaClient.getTableConfig().getPayloadClass().contains(HoodieAvroPayload.class.getName()) - || metaClient.getTableConfig().getPayloadClass().contains("org.apache.hudi.OverwriteWithLatestAvroPayload")); + || metaClient.getTableConfig().getPayloadClass().contains(OverwriteWithLatestAvroPayload.class.getName())); } /**