[FLINK-36315][cdc-base]Variable database changed to namespace

apache · Oct 9, 2024 · f344746 · f344746
1 parent 84ff54e
commit f344746
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ain/java/org/apache/flink/cdc/connectors/base/source/metrics/SourceEnumeratorMetrics.java b/...ain/java/org/apache/flink/cdc/connectors/base/source/metrics/SourceEnumeratorMetrics.java
@@ -49,7 +49,7 @@ public class SourceEnumeratorMetrics {
     public static final String NUM_SNAPSHOT_SPLITS_FINISHED = "numSnapshotSplitsFinished";
     public static final String SNAPSHOT_START_TIME = "snapshotStartTime";
     public static final String SNAPSHOT_END_TIME = "snapshotEndTime";
-    public static final String DATABASE_GROUP_KEY = "database";
+    public static final String NAMESPACE_GROUP_KEY = "namespace";
     public static final String SCHEMA_GROUP_KEY = "schema";
     public static final String TABLE_GROUP_KEY = "table";
 
@@ -138,7 +138,7 @@ public TableMetrics(
             tableName = processNull(tableName);
             MetricGroup metricGroup =
                     parentGroup
-                            .addGroup(DATABASE_GROUP_KEY, databaseName)
+                            .addGroup(NAMESPACE_GROUP_KEY, databaseName)
                             .addGroup(SCHEMA_GROUP_KEY, schemaName)
                             .addGroup(TABLE_GROUP_KEY, tableName);
             metricGroup.gauge(