[hudi] branch master updated: [MINOR] Fix OverwriteWithLatestAvroPayload full class name (#7096)

[xushiyan]

This is an automated email from the ASF dual-hosted git repository.

xushiyan 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 13fd5b93ce [MINOR] Fix OverwriteWithLatestAvroPayload full class name 
(#7096)
13fd5b93ce is described below

commit 13fd5b93ce209803244c3098018872cba522a36a
Author: alberic <cnuliuwei...@gmail.com>
AuthorDate: Tue Nov 1 15:20:11 2022 +0800

    [MINOR] Fix OverwriteWithLatestAvroPayload full class name (#7096)
---
 .../org/apache/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 47da956578..effc007f8e 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 @@ package org.apache.hudi.hadoop.realtime;
 
 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;
@@ -85,7 +86,7 @@ public abstract class AbstractRealtimeRecordReader {
 
   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()));
   }
 
   /**