(inlong) branch master updated: [INLONG-11969][Sort] Fix NullPointer of cdc metric (#11970)

[dockerzhang]

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

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new cf22c92871 [INLONG-11969][Sort] Fix NullPointer of cdc metric (#11970)
cf22c92871 is described below

commit cf22c92871d638ce41b8a2ee90c1f7d141e097c0
Author: vernedeng <verned...@apache.org>
AuthorDate: Mon Aug 18 16:07:58 2025 +0800

    [INLONG-11969][Sort] Fix NullPointer of cdc metric (#11970)
    
    Co-authored-by: vernedeng <verned...@tecent.com>
---
 .../java/org/apache/inlong/sort/base/metric/CdcExactlyMetric.java     | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/CdcExactlyMetric.java
 
b/inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/CdcExactlyMetric.java
index 83d9e4f7dc..fab16eb4dc 100644
--- 
a/inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/CdcExactlyMetric.java
+++ 
b/inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/CdcExactlyMetric.java
@@ -20,6 +20,7 @@ package org.apache.inlong.sort.base.metric;
 import org.apache.inlong.audit.AuditReporterImpl;
 
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections.MapUtils;
 import org.apache.flink.table.data.RowData;
 import org.apache.flink.types.RowKind;
 
@@ -60,6 +61,9 @@ public class CdcExactlyMetric implements Serializable, 
SourceMetricsReporter {
 
     @Override
     public void outputMetricsWithEstimate(Object data, long dataTime) {
+        if (MapUtils.isEmpty(auditKeyMap)) {
+            return;
+        }
         long size = getDataSize(data);
         if (data instanceof RowData) {
             RowData rowData = (RowData) data;