(incubator-paimon) branch release-0.6 updated: [hotfix][cdc] Fix record null check

[yu...@apache.org]

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

yuzelin pushed a commit to branch release-0.6
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git


The following commit(s) were added to refs/heads/release-0.6 by this push:
     new e73b23df4 [hotfix][cdc] Fix record null check
e73b23df4 is described below

commit e73b23df42f951181c079fe8427a13db3e0effae
Author: yuzelin <ze...@alibaba-inc.com>
AuthorDate: Wed Jan 3 16:29:23 2024 +0800

    [hotfix][cdc] Fix record null check
---
 .../org/apache/paimon/flink/action/cdc/mysql/MySqlRecordParser.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlRecordParser.java b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlRecordParser.java
index 9f407173a..031ae2284 100644
--- a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlRecordParser.java
+++ b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlRecordParser.java
@@ -27,6 +27,7 @@ import org.apache.paimon.flink.sink.cdc.RichCdcMultiplexRecord;
 import org.apache.paimon.types.DataType;
 import org.apache.paimon.types.RowKind;
 import org.apache.paimon.utils.DateTimeUtils;
+import org.apache.paimon.utils.JsonSerdeUtil;
 import org.apache.paimon.utils.Preconditions;
 import org.apache.paimon.utils.StringUtils;
 
@@ -240,7 +241,7 @@ public class MySqlRecordParser implements FlatMapFunction<String, RichCdcMultipl
     }
 
     private Map<String, String> extractRow(JsonNode recordRow) {
-        if (recordRow == null) {
+        if (JsonSerdeUtil.isNull(recordRow)) {
             return new HashMap<>();
         }