[FLINK-36315][cdc-base]Fix code style issues

apache · Oct 8, 2024 · 6c00324 · 6c00324
1 parent 9d94c8a
commit 6c00324
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/...va/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceRecordEmitter.java b/...va/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/...k-cdc-base/src/test/java/org/apache/flink/cdc/connectors/base/MySqlSourceMetricsTest.java b/...k-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);