(flink-cdc) branch master updated: [FLINK-38620][pipeline-connector][iceberg] fixed NullPointerException while reporting metrics of Iceberg committer. (#4168)

[kunni]

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

kunni pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git


The following commit(s) were added to refs/heads/master by this push:
     new 6542026d0 [FLINK-38620][pipeline-connector][iceberg] fixed 
NullPointerException while reporting metrics of Iceberg committer. (#4168)
6542026d0 is described below

commit 6542026d0d8e9c07e939c20c76c02b78eb70d9f4
Author: fcfangcc <swjf...@live.com>
AuthorDate: Thu Nov 6 20:10:52 2025 +0800

    [FLINK-38620][pipeline-connector][iceberg] fixed NullPointerException while 
reporting metrics of Iceberg committer. (#4168)
---
 .../apache/flink/cdc/connectors/iceberg/sink/v2/IcebergCommitter.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/IcebergCommitter.java
 
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/IcebergCommitter.java
index 7d4eb5092..9d61a8e43 100644
--- 
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/IcebergCommitter.java
+++ 
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/IcebergCommitter.java
@@ -137,7 +137,9 @@ public class IcebergCommitter implements 
Committer<WriteResultWrapper> {
             }
             MetricGroup tableIdMetricGroup =
                     metricGroup
-                            .addGroup(NAMESPACE_GROUP_KEY, 
tableId.getNamespace())
+                            .addGroup(
+                                    NAMESPACE_GROUP_KEY,
+                                    tableId.getNamespace() == null ? "" : 
tableId.getNamespace())
                             .addGroup(SCHEMA_GROUP_KEY, 
tableId.getSchemaName())
                             .addGroup(TABLE_GROUP_KEY, tableId.getTableName());
             TableMetric tableMetric = new TableMetric(tableIdMetricGroup);