fixed checkstyle

Author: Mrart

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/pom.xml

@@ -164,17 +164,23 @@ limitations under the License.
             </exclusions>
         </dependency>
 
+        <dependency>
+            <groupId>io.debezium</groupId>
+            <artifactId>debezium-connector-mysql</artifactId>
+            <version>1.9.8.Final</version>
+            <scope>compile</scope>
+        </dependency>
         <dependency>
             <groupId>org.apache.flink</groupId>
             <artifactId>flink-cdc-base</artifactId>
-            <version>3.4-SNAPSHOT</version>
+            <version>${project.version}</version>
             <scope>compile</scope>
         </dependency>
         <dependency>
-            <groupId>io.debezium</groupId>
-            <artifactId>debezium-connector-mysql</artifactId>
-            <version>1.9.8.Final</version>
-            <scope>compile</scope>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-connector-test-util</artifactId>
+            <version>${project.version}</version>
+            <scope>test</scope>
         </dependency>
 
     </dependencies>

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/metrics/TiDBSourceMetrics.java

@@ -24,15 +24,15 @@
 import static org.apache.flink.runtime.metrics.MetricNames.CURRENT_FETCH_EVENT_TIME_LAG;
 import static org.apache.flink.runtime.metrics.MetricNames.SOURCE_IDLE_TIME;
 
-/** A collection class for handling metrics in {@link }. */
+/** A collection class for handling metrics in {@link TiKVRichParallelSourceFunction}. */
 public class TiDBSourceMetrics {
 
     private final MetricGroup metricGroup;
 
     /**
-     * The last record processing time, which is updated after {@link } fetches a batch of data.
-     * It's mainly used to report metrics sourceIdleTime for sourceIdleTime =
-     * System.currentTimeMillis() - processTime.
+     * The last record processing time, which is updated after {@link
+     * TiKVRichParallelSourceFunction} fetches a batch of data. It's mainly used to report metrics
+     * sourceIdleTime for sourceIdleTime = System.currentTimeMillis() - processTime.
      */
     private long processTime = 0L;
 

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/source/TiDBDialect.java

@@ -54,6 +54,7 @@
 import java.util.List;
 import java.util.Map;
 
+/** TiDB data source dialect. */
 public class TiDBDialect implements JdbcDataSourceDialect {
     private static final Logger LOG = LoggerFactory.getLogger(TiDBDialect.class);
 

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/source/TiDBSourceBuilder.java

@@ -33,6 +33,7 @@
 
 import static org.apache.flink.cdc.common.utils.Preconditions.checkNotNull;
 
+/** Builder for {@link JdbcIncrementalSource}. */
 public class TiDBSourceBuilder<T> {
     private final TiDBSourceConfigFactory configFactory = new TiDBSourceConfigFactory();
     private EventOffsetFactory offsetFactory;
@@ -187,6 +188,7 @@ public TiDBIncrementalSource<T> build() {
                 configFactory, checkNotNull(deserializer), offsetFactory, dialect);
     }
 
+    /** TiDB incremental source. */
     public static class TiDBIncrementalSource<T> extends JdbcIncrementalSource<T> {
         public TiDBIncrementalSource(
                 JdbcSourceConfigFactory configFactory,

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/source/config/TiDBConnectorConfig.java

@@ -39,6 +39,7 @@
 import java.util.Collections;
 import java.util.List;
 
+/** TiDB connector configuration. */
 public class TiDBConnectorConfig extends RelationalDatabaseConnectorConfig {
     private static final Logger LOGGER = LoggerFactory.getLogger(TiDBConnectorConfig.class);
 
@@ -85,7 +86,8 @@ public class TiDBConnectorConfig extends RelationalDatabaseConnectorConfig {
                                     + "false - delegates the implicit conversion to the database"
                                     + "true - (the default) Debezium makes the conversion");
 
-    public static enum BigIntUnsignedHandlingMode implements EnumeratedValue {
+    /** The set of predefined options for the handling mode configuration property. */
+    public enum BigIntUnsignedHandlingMode implements EnumeratedValue {
         /**
          * Represent {@code BIGINT UNSIGNED} values as precise {@link BigDecimal} values, which are
          * represented in change events in a binary form. This is precise but difficult to use.
@@ -203,7 +205,8 @@ public boolean isReadOnlyConnection() {
         return readOnlyConnection;
     }
 
-    public static enum SecureConnectionMode implements EnumeratedValue {
+    /** Whether to use SSL/TLS to connect to the database. */
+    public enum SecureConnectionMode implements EnumeratedValue {
         /** Establish an unencrypted connection. */
         DISABLED("disabled"),
 

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/source/config/TiDBSourceConfig.java

@@ -29,6 +29,7 @@
 import java.util.Map;
 import java.util.Properties;
 
+/** The configuration for TiDB source. */
 public class TiDBSourceConfig extends JdbcSourceConfig {
     private static final long serialVersionUID = 1L;
     private final String compatibleMode;

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/source/config/TiDBSourceConfigFactory.java

@@ -14,6 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.apache.flink.cdc.connectors.tidb.source.config;
 
 import org.apache.flink.cdc.connectors.base.config.JdbcSourceConfigFactory;

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/source/config/TiDBSourceOptions.java

@@ -14,6 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.apache.flink.cdc.connectors.tidb.source.config;
 
 import org.apache.flink.cdc.connectors.base.options.JdbcSourceOptions;
@@ -28,9 +29,10 @@
 import java.util.Map;
 import java.util.Optional;
 
+/** Options for {@link org.apache.flink.cdc.connectors.tidb.table.TiDBTableSource}. */
 public class TiDBSourceOptions extends JdbcSourceOptions {
 
-    public static final ConfigOption<Integer> TiDB_PORT =
+    public static final ConfigOption<Integer> TIDB_PORT =
             ConfigOptions.key("port")
                     .intType()
                     .defaultValue(4000)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/source/connection/TiDBConnection.java

@@ -54,6 +54,7 @@
 import java.util.function.Supplier;
 import java.util.regex.Pattern;
 
+/** TiDB JDBC connection. */
 public class TiDBConnection extends JdbcConnection {
     private static final Logger LOG = LoggerFactory.getLogger(TiDBConnection.class);
 

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/source/connection/TiDBConnectionPoolFactory.java

@@ -20,6 +20,7 @@
 import org.apache.flink.cdc.connectors.base.config.JdbcSourceConfig;
 import org.apache.flink.cdc.connectors.base.relational.connection.JdbcConnectionPoolFactory;
 
+/** The factory to create {@link TiDBConnectionPool}. */
 public class TiDBConnectionPoolFactory extends JdbcConnectionPoolFactory {
     private static final String MYSQL_URL_PATTERN =
             "jdbc:mysql://%s:%s/?useUnicode=true&useSSL=false&useInformationSchema=true&nullCatalogMeansCurrent=false&zeroDateTimeBehavior=convertToNull&characterEncoding=UTF-8&characterSetResults=UTF-8";