(hudi) branch master updated: [HUDI-7039] PartialUpdateAvroPayload preCombine failed need show details (#10000)

[danny0405]

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 f33459b2ea2 [HUDI-7039] PartialUpdateAvroPayload preCombine failed 
need show details (#10000)
f33459b2ea2 is described below

commit f33459b2ea2ae240b49dcf94d8e7715f57c80c5d
Author: xuzifu666 <x...@zepp.com>
AuthorDate: Wed Nov 8 09:50:03 2023 +0800

    [HUDI-7039] PartialUpdateAvroPayload preCombine failed need show details 
(#10000)
    
    Co-authored-by: xuyu <11161...@vivo.com>
---
 .../java/org/apache/hudi/common/model/PartialUpdateAvroPayload.java  | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/hudi-common/src/main/java/org/apache/hudi/common/model/PartialUpdateAvroPayload.java
 
b/hudi-common/src/main/java/org/apache/hudi/common/model/PartialUpdateAvroPayload.java
index 27e744c4925..91b66e004e5 100644
--- 
a/hudi-common/src/main/java/org/apache/hudi/common/model/PartialUpdateAvroPayload.java
+++ 
b/hudi-common/src/main/java/org/apache/hudi/common/model/PartialUpdateAvroPayload.java
@@ -29,6 +29,8 @@ import org.apache.hudi.common.util.Option;
 import org.apache.hudi.common.util.ReflectionUtils;
 import org.apache.hudi.common.util.StringUtils;
 import org.apache.hudi.keygen.constant.KeyGeneratorOptions;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.io.IOException;
 import java.util.List;
@@ -117,6 +119,8 @@ import java.util.Properties;
  */
 public class PartialUpdateAvroPayload extends 
OverwriteNonDefaultsWithLatestAvroPayload {
 
+  private static final Logger LOG = 
LoggerFactory.getLogger(PartialUpdateAvroPayload.class);
+
   public PartialUpdateAvroPayload(GenericRecord record, Comparable 
orderingVal) {
     super(record, orderingVal);
   }
@@ -141,6 +145,7 @@ public class PartialUpdateAvroPayload extends 
OverwriteNonDefaultsWithLatestAvro
             shouldPickOldRecord ? oldValue.orderingVal : this.orderingVal);
       }
     } catch (Exception ex) {
+      LOG.warn("PartialUpdateAvroPayload precombine failed with ", ex);
       return this;
     }
     return this;