[tidb] Bump tikv client version to v3.2.0

flink-connector-tidb-cdc/src/main/java/com/ververica/cdc/connectors/tidb/TiDBSource.java

@@ -1,4 +1,4 @@
-package com.ververica.cdc.connectors.tidb; /*
+/*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
@@ -16,6 +16,8 @@ package com.ververica.cdc.connectors.tidb; /*
  * limitations under the License.
  */
 
+package com.ververica.cdc.connectors.tidb;
+
 import org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction;
 
 import com.ververica.cdc.connectors.tidb.table.StartupOptions;

flink-connector-tidb-cdc/src/main/java/com/ververica/cdc/connectors/tidb/TiKVRichParallelSourceFunction.java

@@ -185,8 +185,6 @@ public class TiKVRichParallelSourceFunction<T> extends RichParallelSourceFunctio
                                 .next()
                                 .toByteString();
             }
-        } catch (Exception e) {
-            e.printStackTrace();
         } finally {
             scanClient.close();
         }

flink-connector-tidb-cdc/src/test/java/com/ververica/cdc/connectors/tidb/table/TiDBConnectorITCase.java

@@ -32,11 +32,10 @@ import org.apache.flink.util.TestLogger;
 
 import org.junit.Before;
 import org.junit.ClassRule;
-import org.junit.Ignore;
 import org.junit.Rule;
 import org.junit.Test;
+import org.junit.Ignore;
 
-import java.net.URL;
 import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.Statement;
@@ -83,7 +82,6 @@ public class TiDBConnectorITCase extends TestLogger {
     }
 
     @Test
-    @Ignore("Test ignored because it need manually install TiDB suites by TiUP")
     public void testConsumingAllEvents() throws Exception {
         String sourceDDL =
                 String.format(

pom.xml

@@ -47,7 +47,6 @@ under the License.
         <module>flink-sql-connector-oracle-cdc</module>
         <module>flink-sql-connector-sqlserver-cdc</module>
         <module>flink-sql-connector-tidb-cdc</module>
-        <module>flink-format-changelog-json</module>
         <module>flink-cdc-e2e-tests</module>
     </modules>
 
@@ -73,7 +72,7 @@ under the License.
     <properties>
         <flink.version>1.13.5</flink.version>
         <debezium.version>1.5.4.Final</debezium.version>
-        <tikv.version>3.2.0-SNAPSHOT</tikv.version>
+        <tikv.version>3.2.0</tikv.version>
         <geometry.version>2.2.0</geometry.version>
         <!-- OracleE2eITCase will report "container cannot be accessed" error when running in Azure Pipeline with 1.16.1 testconainters.
           This might be a conflicts with "wnameless/oracle-xe-11g-r2" and 1.16 testcontainers.