From 6c00324376594a13a4d77136fb97db9bffac80a3 Mon Sep 17 00:00:00 2001
From: "molin.lxd" <molin.lxd@alibaba-inc.com>
Date: Tue, 8 Oct 2024 14:26:32 +0800
Subject: [PATCH] [FLINK-36315][cdc-base]Fix code style issues

---
 .../base/source/reader/IncrementalSourceRecordEmitter.java   | 5 +++++
 .../flink/cdc/connectors/base/MySqlSourceMetricsTest.java    | 2 +-
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceRecordEmitter.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceRecordEmitter.java
index b934625033..f3a0646250 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceRecordEmitter.java
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceRecordEmitter.java
@@ -172,6 +172,11 @@ protected void reportMetrics(SourceRecord element) {
         }
     }
 
+    /**
+     * Collector for outputting records.
+     *
+     * @param <T>
+     */
     protected static class OutputCollector<T> implements Collector<T> {
         public SourceOutput<T> output;
         public Long currentMessageTimestamp;
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/test/java/org/apache/flink/cdc/connectors/base/MySqlSourceMetricsTest.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/test/java/org/apache/flink/cdc/connectors/base/MySqlSourceMetricsTest.java
index a41780707d..68dd1a7713 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/test/java/org/apache/flink/cdc/connectors/base/MySqlSourceMetricsTest.java
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/test/java/org/apache/flink/cdc/connectors/base/MySqlSourceMetricsTest.java
@@ -69,7 +69,7 @@
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertTrue;
 
-/** MySQL Source Metrics Tests */
+/** MySQL Source Metrics Tests. */
 public class MySqlSourceMetricsTest {
 
     private static final Logger LOG = LoggerFactory.getLogger(MySqlSourceMetricsTest.class);