From f3447469fa92967d8b17651831cc59d459cd004c Mon Sep 17 00:00:00 2001 From: "molin.lxd" Date: Wed, 9 Oct 2024 16:17:31 +0800 Subject: [PATCH] [FLINK-36315][cdc-base]Variable database changed to namespace --- .../base/source/metrics/SourceEnumeratorMetrics.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/metrics/SourceEnumeratorMetrics.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/metrics/SourceEnumeratorMetrics.java index e47a40c979..e739935111 100644 --- a/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/metrics/SourceEnumeratorMetrics.java +++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/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(