formatting fixes

Author: tejanshrana

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlPipelineRecordEmitter.java

@@ -93,7 +93,7 @@ public MySqlPipelineRecordEmitter(
                 debeziumDeserializationSchema,
                 sourceReaderMetrics,
                 sourceConfig.isIncludeSchemaChanges(),
-          false); // Explicitly disable transaction metadata events
+                false); // Explicitly disable transaction metadata events
         this.debeziumDeserializationSchema = debeziumDeserializationSchema;
         this.sourceConfig = sourceConfig;
         this.alreadySendCreateTableTables = new HashSet<>();

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

@@ -199,7 +199,8 @@ public MySqlSourceBuilder<T> includeSchemaChanges(boolean includeSchemaChanges)
     }
 
     /** Whether the {@link MySqlSource} should output the transaction metadata events or not. */
-    public MySqlSourceBuilder<T> includeTransactionMetadataEvents(boolean includeTransactionMetadataEvents) {
+    public MySqlSourceBuilder<T> includeTransactionMetadataEvents(
+            boolean includeTransactionMetadataEvents) {
         this.configFactory.includeTransactionMetadataEvents(includeTransactionMetadataEvents);
         return this;
     }

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

@@ -237,7 +237,8 @@ public MySqlSourceConfigFactory includeSchemaChanges(boolean includeSchemaChange
     }
 
     /** Whether the {@link MySqlSource} should output the transaction metadata events or not. */
-    public MySqlSourceConfigFactory includeTransactionMetadataEvents(boolean includeTransactionMetadataEvents) {
+    public MySqlSourceConfigFactory includeTransactionMetadataEvents(
+            boolean includeTransactionMetadataEvents) {
         this.includeTransactionMetadataEvents = includeTransactionMetadataEvents;
         return this;
     }
@@ -367,7 +368,8 @@ public MySqlSourceConfig createConfig(int subtaskId, String serverName) {
         // only DataStream API program need to emit the schema record, the Table API need not
         props.setProperty("include.schema.changes", String.valueOf(true));
         // enable transaction metadata if includeTransactionMetadataEvents is true
-        props.setProperty("provide.transaction.metadata", String.valueOf(includeTransactionMetadataEvents));
+        props.setProperty(
+                "provide.transaction.metadata", 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/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/RecordUtils.java

@@ -348,9 +348,9 @@ public static boolean isHeartbeatEvent(SourceRecord record) {
      * provide.transaction.metadata is enabled.
      */
     public static boolean isTransactionMetadataEvent(SourceRecord record) {
-       Schema keySchema = record.keySchema();
+        Schema keySchema = record.keySchema();
         return keySchema != null
-                 && SCHEMA_TRANSACTION_METADATA_EVENT_KEY_NAME.equalsIgnoreCase(keySchema.name());
+                && SCHEMA_TRANSACTION_METADATA_EVENT_KEY_NAME.equalsIgnoreCase(keySchema.name());
     }
 
     /**