review comment; formatting

Author: tejanshrana

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceConfigFactory.java

@@ -23,6 +23,8 @@
 import org.apache.flink.cdc.connectors.mysql.table.StartupOptions;
 import org.apache.flink.table.catalog.ObjectPath;
 
+import io.debezium.config.CommonConnectorConfig;
+
 import java.io.Serializable;
 import java.time.Duration;
 import java.time.ZoneId;
@@ -376,7 +378,8 @@ public MySqlSourceConfig createConfig(int subtaskId, String serverName) {
         props.setProperty("include.schema.changes", String.valueOf(true));
         // enable transaction metadata if includeTransactionMetadataEvents is true
         props.setProperty(
-                "provide.transaction.metadata", String.valueOf(includeTransactionMetadataEvents));
+                CommonConnectorConfig.PROVIDE_TRANSACTION_METADATA.name(),
+                String.valueOf(includeTransactionMetadataEvents));
         // disable the offset flush totally
         props.setProperty("offset.flush.interval.ms", String.valueOf(Long.MAX_VALUE));
         // disable tombstones

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlRecordEmitterTest.java

@@ -111,7 +111,7 @@ public TypeInformation<Void> getProducedType() {
                         UnregisteredMetricGroups.createUnregisteredOperatorMetricGroup()),
                 false,
                 false,
-        false);
+                false);
     }
 
     @Test

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlSourceReaderTest.java

@@ -742,7 +742,12 @@ public MysqlLimitedRecordEmitter(
                 MySqlSourceReaderMetrics sourceReaderMetrics,
                 boolean includeSchemaChanges,
                 int limit) {
-            super(debeziumDeserializationSchema, sourceReaderMetrics, includeSchemaChanges, false, false);
+            super(
+                    debeziumDeserializationSchema,
+                    sourceReaderMetrics,
+                    includeSchemaChanges,
+                    false,
+                    false);
             this.debeziumDeserializationSchema = debeziumDeserializationSchema;
             this.sourceReaderMetrics = sourceReaderMetrics;
             this.includeSchemaChanges = includeSchemaChanges;