[INLONG-11349][Sort] Added enable.log.report configuration for connec…

…tors
apache · Dec 10, 2024 · 22fa6f7 · 22fa6f7
1 parent 0a936e2
commit 22fa6f7
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 8 deletions.
diff --git a/inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/Constants.java b/inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/Constants.java
@@ -469,4 +469,10 @@ public final class Constants {
                     .withDescription(
                             "pulsar client auth params");
 
+    public static final ConfigOption<Boolean> ENABLE_LOG_REPORT =
+            ConfigOptions.key("enable.log.report")
+                    .booleanType()
+                    .defaultValue(false)
+                    .withDescription("Whether enable openTelemetry log report or not.");
+
 }
diff --git a/...rt-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/mysql/MysqlTableFactory.java b/...rt-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/mysql/MysqlTableFactory.java
@@ -17,6 +17,7 @@
 
 package org.apache.inlong.sort.mysql;
 
+import org.apache.inlong.sort.base.Constants;
 import org.apache.inlong.sort.base.metric.MetricOption;
 
 import com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions;
@@ -69,7 +70,7 @@ public DynamicTableSource createDynamicTableSource(Context context) {
         final String username = config.get(USERNAME);
         final String password = config.get(PASSWORD);
         final String databaseName = config.get(DATABASE_NAME);
-        final Boolean enableLogReport = context.getConfiguration().get(ENABLE_LOG_REPORT);
+        final Boolean enableLogReport = context.getConfiguration().get(Constants.ENABLE_LOG_REPORT);
         validateRegex(DATABASE_NAME.key(), databaseName);
         final String tableName = config.get(TABLE_NAME);
         validateRegex(TABLE_NAME.key(), tableName);
@@ -339,13 +340,6 @@ public Set<ConfigOption<?>> optionalOptions() {
                             + "\"-U\" represents UPDATE_BEFORE.\n"
                             + "\"+U\" represents UPDATE_AFTER.\n"
                             + "\"-D\" represents DELETE.");
-
-    public static final ConfigOption<Boolean> ENABLE_LOG_REPORT =
-            ConfigOptions.key("enable.log.report")
-                    .booleanType()
-                    .defaultValue(false)
-                    .withDescription("Whether enable openTelemetry log report or not.");
-
     // ----------------------------------------------------------------------------
     // experimental options, won't add them to documentation
     // ----------------------------------------------------------------------------