This is an automated email from the ASF dual-hosted git repository.
fanrui pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-jdbc.git
The following commit(s) were added to refs/heads/main by this push:
new 099cda71 [hotfix][test] Change the modifier visibility of JUnit5.
099cda71 is described below
commit 099cda7142944160b18ff2ddd0c3597013e116d4
Author: Roc Marshal <[email protected]>
AuthorDate: Mon Jul 15 12:22:53 2024 +0800
[hotfix][test] Change the modifier visibility of JUnit5.
---
.../jdbc/databases/cratedb/dialect/CrateDBDialectTypeTest.java | 2 +-
.../flink/connector/jdbc/databases/db2/dialect/Db2DialectTypeTest.java | 2 +-
.../connector/jdbc/databases/db2/table/Db2DynamicTableSinkITCase.java | 2 +-
.../jdbc/databases/db2/table/Db2DynamicTableSourceITCase.java | 3 +--
.../connector/jdbc/databases/db2/xa/Db2ExactlyOnceSinkE2eTest.java | 2 +-
.../jdbc/databases/derby/table/DerbyDynamicTableSinkITCase.java | 3 +--
.../jdbc/databases/derby/table/DerbyDynamicTableSourceITCase.java | 3 +--
.../connector/jdbc/databases/derby/xa/DerbyExactlyOnceSinkE2eTest.java | 3 +--
.../connector/jdbc/databases/mysql/catalog/MySql56CatalogITCase.java | 2 +-
.../connector/jdbc/databases/mysql/catalog/MySql57CatalogITCase.java | 2 +-
.../connector/jdbc/databases/mysql/catalog/MySqlCatalogITCase.java | 2 +-
.../connector/jdbc/databases/mysql/catalog/MySqlCatalogTestBase.java | 2 +-
.../connector/jdbc/databases/mysql/dialect/MySqlDialectTypeTest.java | 2 +-
.../jdbc/databases/mysql/table/MySqlDynamicTableSinkITCase.java | 3 +--
.../jdbc/databases/mysql/table/MySqlDynamicTableSourceITCase.java | 3 +--
.../connector/jdbc/databases/mysql/xa/MySqlExactlyOnceSinkE2eTest.java | 3 +--
.../jdbc/databases/oceanbase/dialect/OceanBaseDialectTest.java | 2 +-
.../databases/oceanbase/dialect/OceanBaseMysqlDialectTypeTest.java | 2 +-
.../databases/oceanbase/dialect/OceanBaseOracleDialectTypeTest.java | 2 +-
.../oceanbase/table/OceanBaseMySqlDynamicTableSinkITCase.java | 2 +-
.../oceanbase/table/OceanBaseMySqlDynamicTableSourceITCase.java | 2 +-
.../oceanbase/table/OceanBaseOracleDynamicTableSinkITCase.java | 2 +-
.../oceanbase/table/OceanBaseOracleDynamicTableSourceITCase.java | 2 +-
.../connector/jdbc/databases/oracle/dialect/OracleDialectTypeTest.java | 2 +-
.../jdbc/databases/oracle/table/OracleDynamicTableSinkITCase.java | 3 +--
.../jdbc/databases/oracle/table/OracleDynamicTableSourceITCase.java | 2 +-
.../jdbc/databases/oracle/xa/OracleExactlyOnceSinkE2eTest.java | 3 +--
.../jdbc/databases/postgres/dialect/PostgresDialectTypeTest.java | 2 +-
.../jdbc/databases/postgres/table/PostgresDynamicTableSinkITCase.java | 2 +-
.../databases/postgres/table/PostgresDynamicTableSourceITCase.java | 2 +-
.../jdbc/databases/postgres/xa/PostgresExactlyOnceSinkE2eTest.java | 2 +-
.../databases/sqlserver/table/SqlServerDynamicTableSinkITCase.java | 2 +-
.../databases/sqlserver/table/SqlServerDynamicTableSourceITCase.java | 2 +-
.../jdbc/databases/sqlserver/xa/SqlServerExactlyOnceSinkE2eTest.java | 2 +-
.../org/apache/flink/connector/jdbc/sink/AtLeastOnceJdbcSinkTest.java | 2 +-
.../org/apache/flink/connector/jdbc/sink/ExactlyOnceJdbcSinkTest.java | 2 +-
.../java/org/apache/flink/connector/jdbc/table/JdbcTablePlanTest.java | 2 +-
.../org/apache/flink/connector/jdbc/xa/JdbcXaSinkMigrationTest.java | 2 +-
38 files changed, 38 insertions(+), 47 deletions(-)
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/cratedb/dialect/CrateDBDialectTypeTest.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/cratedb/dialect/CrateDBDialectTypeTest.java
index 8f95af48..9e90e336 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/cratedb/dialect/CrateDBDialectTypeTest.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/cratedb/dialect/CrateDBDialectTypeTest.java
@@ -24,7 +24,7 @@ import java.util.Arrays;
import java.util.List;
/** The CrateDB params for {@link JdbcDialectTypeTest}. */
-public class CrateDBDialectTypeTest extends JdbcDialectTypeTest {
+class CrateDBDialectTypeTest extends JdbcDialectTypeTest {
@Override
protected String testDialect() {
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/db2/dialect/Db2DialectTypeTest.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/db2/dialect/Db2DialectTypeTest.java
index 4f687a69..31e364a2 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/db2/dialect/Db2DialectTypeTest.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/db2/dialect/Db2DialectTypeTest.java
@@ -24,7 +24,7 @@ import java.util.Arrays;
import java.util.List;
/** The Db2 params for {@link JdbcDialectTypeTest}. */
-public class Db2DialectTypeTest extends JdbcDialectTypeTest {
+class Db2DialectTypeTest extends JdbcDialectTypeTest {
@Override
protected String testDialect() {
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/db2/table/Db2DynamicTableSinkITCase.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/db2/table/Db2DynamicTableSinkITCase.java
index f7e3eb0b..d486b999 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/db2/table/Db2DynamicTableSinkITCase.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/db2/table/Db2DynamicTableSinkITCase.java
@@ -30,7 +30,7 @@ import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.pkFi
import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.tableRow;
/** The Table Sink ITCase for {@link Db2Dialect}. */
-public class Db2DynamicTableSinkITCase extends JdbcDynamicTableSinkITCase
implements Db2TestBase {
+class Db2DynamicTableSinkITCase extends JdbcDynamicTableSinkITCase implements
Db2TestBase {
@Override
protected TableRow createUpsertOutputTable() {
return tableRow(
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/db2/table/Db2DynamicTableSourceITCase.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/db2/table/Db2DynamicTableSourceITCase.java
index d92217a2..c632ec4a 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/db2/table/Db2DynamicTableSourceITCase.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/db2/table/Db2DynamicTableSourceITCase.java
@@ -37,8 +37,7 @@ import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.fiel
import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.tableRow;
/** The Table Source ITCase for {@link Db2Dialect}. */
-public class Db2DynamicTableSourceITCase extends JdbcDynamicTableSourceITCase
- implements Db2TestBase {
+class Db2DynamicTableSourceITCase extends JdbcDynamicTableSourceITCase
implements Db2TestBase {
@Override
protected TableRow createInputTable() {
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/db2/xa/Db2ExactlyOnceSinkE2eTest.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/db2/xa/Db2ExactlyOnceSinkE2eTest.java
index 01e0aea7..d375b702 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/db2/xa/Db2ExactlyOnceSinkE2eTest.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/db2/xa/Db2ExactlyOnceSinkE2eTest.java
@@ -22,4 +22,4 @@ import
org.apache.flink.connector.jdbc.databases.db2.Db2TestBase;
import org.apache.flink.connector.jdbc.xa.JdbcExactlyOnceSinkE2eTest;
/** A simple end-to-end test for {@link JdbcExactlyOnceSinkE2eTest}. */
-public class Db2ExactlyOnceSinkE2eTest extends JdbcExactlyOnceSinkE2eTest
implements Db2TestBase {}
+class Db2ExactlyOnceSinkE2eTest extends JdbcExactlyOnceSinkE2eTest implements
Db2TestBase {}
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/derby/table/DerbyDynamicTableSinkITCase.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/derby/table/DerbyDynamicTableSinkITCase.java
index acd2ad9f..80b54b75 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/derby/table/DerbyDynamicTableSinkITCase.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/derby/table/DerbyDynamicTableSinkITCase.java
@@ -23,5 +23,4 @@ import
org.apache.flink.connector.jdbc.databases.derby.dialect.DerbyDialect;
import org.apache.flink.connector.jdbc.table.JdbcDynamicTableSinkITCase;
/** The Table Sink ITCase for {@link DerbyDialect}. */
-public class DerbyDynamicTableSinkITCase extends JdbcDynamicTableSinkITCase
- implements DerbyTestBase {}
+class DerbyDynamicTableSinkITCase extends JdbcDynamicTableSinkITCase
implements DerbyTestBase {}
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/derby/table/DerbyDynamicTableSourceITCase.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/derby/table/DerbyDynamicTableSourceITCase.java
index fa1d6735..dd5e4939 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/derby/table/DerbyDynamicTableSourceITCase.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/derby/table/DerbyDynamicTableSourceITCase.java
@@ -36,8 +36,7 @@ import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.fiel
import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.tableRow;
/** The Table Source ITCase for {@link DerbyDialect}. */
-public class DerbyDynamicTableSourceITCase extends JdbcDynamicTableSourceITCase
- implements DerbyTestBase {
+class DerbyDynamicTableSourceITCase extends JdbcDynamicTableSourceITCase
implements DerbyTestBase {
protected TableRow createInputTable() {
return tableRow(
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/derby/xa/DerbyExactlyOnceSinkE2eTest.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/derby/xa/DerbyExactlyOnceSinkE2eTest.java
index 2757d0e9..6c938fd0 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/derby/xa/DerbyExactlyOnceSinkE2eTest.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/derby/xa/DerbyExactlyOnceSinkE2eTest.java
@@ -25,5 +25,4 @@ import
org.apache.flink.connector.jdbc.xa.JdbcExactlyOnceSinkE2eTest;
* A simple end-to-end test for {@link JdbcExactlyOnceSinkE2eTest}. Check for
issues with errors on
* closing connections.
*/
-public class DerbyExactlyOnceSinkE2eTest extends JdbcExactlyOnceSinkE2eTest
- implements DerbyTestBase {}
+class DerbyExactlyOnceSinkE2eTest extends JdbcExactlyOnceSinkE2eTest
implements DerbyTestBase {}
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySql56CatalogITCase.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySql56CatalogITCase.java
index fbfcae22..ef56ce11 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySql56CatalogITCase.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySql56CatalogITCase.java
@@ -24,7 +24,7 @@ import
org.apache.flink.connector.jdbc.testutils.databases.mysql.MySql56Database
import org.junit.jupiter.api.extension.RegisterExtension;
/** E2E test for {@link MySqlCatalog} with MySql version 5.6. */
-public class MySql56CatalogITCase extends MySqlCatalogTestBase {
+class MySql56CatalogITCase extends MySqlCatalogTestBase {
@RegisterExtension private static final MySql56Database DATABASE = new
MySql56Database();
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySql57CatalogITCase.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySql57CatalogITCase.java
index c48bf5fc..39ac27a9 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySql57CatalogITCase.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySql57CatalogITCase.java
@@ -24,7 +24,7 @@ import
org.apache.flink.connector.jdbc.testutils.databases.mysql.MySql57Database
import org.junit.jupiter.api.extension.RegisterExtension;
/** E2E test for {@link MySqlCatalog} with MySql version 5.7. */
-public class MySql57CatalogITCase extends MySqlCatalogTestBase {
+class MySql57CatalogITCase extends MySqlCatalogTestBase {
@RegisterExtension private static final MySql57Database DATABASE = new
MySql57Database();
@Override
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySqlCatalogITCase.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySqlCatalogITCase.java
index daf1a8ac..f55cf3ae 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySqlCatalogITCase.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySqlCatalogITCase.java
@@ -21,4 +21,4 @@ package
org.apache.flink.connector.jdbc.databases.mysql.catalog;
import org.apache.flink.connector.jdbc.databases.mysql.MySqlTestBase;
/** E2E test for {@link MySqlCatalog}. */
-public class MySqlCatalogITCase extends MySqlCatalogTestBase implements
MySqlTestBase {}
+class MySqlCatalogITCase extends MySqlCatalogTestBase implements MySqlTestBase
{}
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySqlCatalogTestBase.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySqlCatalogTestBase.java
index 2bf29b3f..aa744f2e 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySqlCatalogTestBase.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySqlCatalogTestBase.java
@@ -62,7 +62,7 @@ import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatThrownBy;
/** Test base for {@link MySqlCatalog}. */
-public abstract class MySqlCatalogTestBase implements JdbcITCaseBase,
DatabaseTest {
+abstract class MySqlCatalogTestBase implements JdbcITCaseBase, DatabaseTest {
private static final Logger LOG =
LoggerFactory.getLogger(MySqlCatalogTestBase.class);
private static final String TEST_CATALOG_NAME = "mysql_catalog";
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/dialect/MySqlDialectTypeTest.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/dialect/MySqlDialectTypeTest.java
index f636c362..dac699cb 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/dialect/MySqlDialectTypeTest.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/dialect/MySqlDialectTypeTest.java
@@ -24,7 +24,7 @@ import java.util.Arrays;
import java.util.List;
/** The MySql params for {@link JdbcDialectTypeTest}. */
-public class MySqlDialectTypeTest extends JdbcDialectTypeTest {
+class MySqlDialectTypeTest extends JdbcDialectTypeTest {
@Override
protected String testDialect() {
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/table/MySqlDynamicTableSinkITCase.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/table/MySqlDynamicTableSinkITCase.java
index 2efe39de..c742edc7 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/table/MySqlDynamicTableSinkITCase.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/table/MySqlDynamicTableSinkITCase.java
@@ -30,8 +30,7 @@ import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.pkFi
import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.tableRow;
/** The Table Sink ITCase for {@link MySqlDialect}. */
-public class MySqlDynamicTableSinkITCase extends JdbcDynamicTableSinkITCase
- implements MySqlTestBase {
+class MySqlDynamicTableSinkITCase extends JdbcDynamicTableSinkITCase
implements MySqlTestBase {
@Override
protected TableRow createUpsertOutputTable() {
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/table/MySqlDynamicTableSourceITCase.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/table/MySqlDynamicTableSourceITCase.java
index 967c7e84..d5b27dc9 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/table/MySqlDynamicTableSourceITCase.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/table/MySqlDynamicTableSourceITCase.java
@@ -36,8 +36,7 @@ import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.fiel
import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.tableRow;
/** The Table Source ITCase for {@link MySqlDialect}. */
-public class MySqlDynamicTableSourceITCase extends JdbcDynamicTableSourceITCase
- implements MySqlTestBase {
+class MySqlDynamicTableSourceITCase extends JdbcDynamicTableSourceITCase
implements MySqlTestBase {
@Override
protected TableRow createInputTable() {
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/xa/MySqlExactlyOnceSinkE2eTest.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/xa/MySqlExactlyOnceSinkE2eTest.java
index 01a15f1e..18371cd3 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/xa/MySqlExactlyOnceSinkE2eTest.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/xa/MySqlExactlyOnceSinkE2eTest.java
@@ -25,5 +25,4 @@ import
org.apache.flink.connector.jdbc.xa.JdbcExactlyOnceSinkE2eTest;
* A simple end-to-end test for {@link JdbcExactlyOnceSinkE2eTest}. Check for
issues with errors on
* closing connections.
*/
-public class MySqlExactlyOnceSinkE2eTest extends JdbcExactlyOnceSinkE2eTest
- implements MySqlTestBase {}
+class MySqlExactlyOnceSinkE2eTest extends JdbcExactlyOnceSinkE2eTest
implements MySqlTestBase {}
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/dialect/OceanBaseDialectTest.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/dialect/OceanBaseDialectTest.java
index 7bab63b7..7edeef75 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/dialect/OceanBaseDialectTest.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/dialect/OceanBaseDialectTest.java
@@ -23,7 +23,7 @@ import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat;
/** Tests for {@link OceanBaseDialect}. */
-public class OceanBaseDialectTest {
+class OceanBaseDialectTest {
@Test
void testMysqlAppendDefaultUrlProperties() {
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/dialect/OceanBaseMysqlDialectTypeTest.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/dialect/OceanBaseMysqlDialectTypeTest.java
index 675280c4..09daadaf 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/dialect/OceanBaseMysqlDialectTypeTest.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/dialect/OceanBaseMysqlDialectTypeTest.java
@@ -24,7 +24,7 @@ import java.util.Arrays;
import java.util.List;
/** The OceanBase MySql mode params for {@link JdbcDialectTypeTest}. */
-public class OceanBaseMysqlDialectTypeTest extends JdbcDialectTypeTest {
+class OceanBaseMysqlDialectTypeTest extends JdbcDialectTypeTest {
public OceanBaseMysqlDialectTypeTest() {
ddlFormat =
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/dialect/OceanBaseOracleDialectTypeTest.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/dialect/OceanBaseOracleDialectTypeTest.java
index f58d7014..21d46a3b 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/dialect/OceanBaseOracleDialectTypeTest.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/dialect/OceanBaseOracleDialectTypeTest.java
@@ -24,7 +24,7 @@ import java.util.Arrays;
import java.util.List;
/** The OceanBase Oracle mode params for {@link JdbcDialectTypeTest}. */
-public class OceanBaseOracleDialectTypeTest extends JdbcDialectTypeTest {
+class OceanBaseOracleDialectTypeTest extends JdbcDialectTypeTest {
public OceanBaseOracleDialectTypeTest() {
ddlFormat =
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/table/OceanBaseMySqlDynamicTableSinkITCase.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/table/OceanBaseMySqlDynamicTableSinkITCase.java
index 67f55152..aecde26a 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/table/OceanBaseMySqlDynamicTableSinkITCase.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/table/OceanBaseMySqlDynamicTableSinkITCase.java
@@ -30,7 +30,7 @@ import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.fiel
import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.pkField;
/** The Table Sink ITCase for OceanBase MySql mode. */
-public class OceanBaseMySqlDynamicTableSinkITCase extends
JdbcDynamicTableSinkITCase
+class OceanBaseMySqlDynamicTableSinkITCase extends JdbcDynamicTableSinkITCase
implements OceanBaseMysqlTestBase {
@Override
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/table/OceanBaseMySqlDynamicTableSourceITCase.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/table/OceanBaseMySqlDynamicTableSourceITCase.java
index 441b1715..5e96be83 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/table/OceanBaseMySqlDynamicTableSourceITCase.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/table/OceanBaseMySqlDynamicTableSourceITCase.java
@@ -35,7 +35,7 @@ import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.fiel
import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.pkField;
/** The Table Source ITCase for OceanBase MySql mode. */
-public class OceanBaseMySqlDynamicTableSourceITCase extends
JdbcDynamicTableSourceITCase
+class OceanBaseMySqlDynamicTableSourceITCase extends
JdbcDynamicTableSourceITCase
implements OceanBaseMysqlTestBase {
@Override
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/table/OceanBaseOracleDynamicTableSinkITCase.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/table/OceanBaseOracleDynamicTableSinkITCase.java
index e9e06fa4..7569b7bb 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/table/OceanBaseOracleDynamicTableSinkITCase.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/table/OceanBaseOracleDynamicTableSinkITCase.java
@@ -37,7 +37,7 @@ import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.pkFi
/** The Table Sink ITCase for OceanBase Oracle mode. */
@Disabled
-public class OceanBaseOracleDynamicTableSinkITCase extends
JdbcDynamicTableSinkITCase
+class OceanBaseOracleDynamicTableSinkITCase extends JdbcDynamicTableSinkITCase
implements OceanBaseOracleTestBase {
@Override
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/table/OceanBaseOracleDynamicTableSourceITCase.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/table/OceanBaseOracleDynamicTableSourceITCase.java
index a1a6fce5..9f94fa73 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/table/OceanBaseOracleDynamicTableSourceITCase.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/table/OceanBaseOracleDynamicTableSourceITCase.java
@@ -37,7 +37,7 @@ import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.fiel
/** The Table Source ITCase for OceanBase Oracle mode. */
@Disabled
-public class OceanBaseOracleDynamicTableSourceITCase extends
JdbcDynamicTableSourceITCase
+class OceanBaseOracleDynamicTableSourceITCase extends
JdbcDynamicTableSourceITCase
implements OceanBaseOracleTestBase {
@Override
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oracle/dialect/OracleDialectTypeTest.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oracle/dialect/OracleDialectTypeTest.java
index 93ba4d4b..d4526791 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oracle/dialect/OracleDialectTypeTest.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oracle/dialect/OracleDialectTypeTest.java
@@ -24,7 +24,7 @@ import java.util.Arrays;
import java.util.List;
/** The Oracle params for {@link JdbcDialectTypeTest}. */
-public class OracleDialectTypeTest extends JdbcDialectTypeTest {
+class OracleDialectTypeTest extends JdbcDialectTypeTest {
@Override
protected String testDialect() {
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oracle/table/OracleDynamicTableSinkITCase.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oracle/table/OracleDynamicTableSinkITCase.java
index 2bb3cf15..a98c5ec1 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oracle/table/OracleDynamicTableSinkITCase.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oracle/table/OracleDynamicTableSinkITCase.java
@@ -35,8 +35,7 @@ import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.pkFi
import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.tableRow;
/** The Table Sink ITCase for {@link OracleDialect}. */
-public class OracleDynamicTableSinkITCase extends JdbcDynamicTableSinkITCase
- implements OracleTestBase {
+class OracleDynamicTableSinkITCase extends JdbcDynamicTableSinkITCase
implements OracleTestBase {
@Override
protected TableRow createUpsertOutputTable() {
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oracle/table/OracleDynamicTableSourceITCase.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oracle/table/OracleDynamicTableSourceITCase.java
index 9e758eee..ff7e0254 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oracle/table/OracleDynamicTableSourceITCase.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oracle/table/OracleDynamicTableSourceITCase.java
@@ -36,7 +36,7 @@ import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.fiel
import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.tableRow;
/** The Table Source ITCase for {@link OracleDialect}. */
-public class OracleDynamicTableSourceITCase extends
JdbcDynamicTableSourceITCase
+class OracleDynamicTableSourceITCase extends JdbcDynamicTableSourceITCase
implements OracleTestBase {
@Override
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oracle/xa/OracleExactlyOnceSinkE2eTest.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oracle/xa/OracleExactlyOnceSinkE2eTest.java
index 08ab8cd7..5498b551 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oracle/xa/OracleExactlyOnceSinkE2eTest.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oracle/xa/OracleExactlyOnceSinkE2eTest.java
@@ -22,5 +22,4 @@ import
org.apache.flink.connector.jdbc.databases.oracle.OracleTestBase;
import org.apache.flink.connector.jdbc.xa.JdbcExactlyOnceSinkE2eTest;
/** A simple end-to-end test for {@link JdbcExactlyOnceSinkE2eTest}. */
-public class OracleExactlyOnceSinkE2eTest extends JdbcExactlyOnceSinkE2eTest
- implements OracleTestBase {}
+class OracleExactlyOnceSinkE2eTest extends JdbcExactlyOnceSinkE2eTest
implements OracleTestBase {}
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres/dialect/PostgresDialectTypeTest.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres/dialect/PostgresDialectTypeTest.java
index ce1c4e8e..1da9b971 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres/dialect/PostgresDialectTypeTest.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres/dialect/PostgresDialectTypeTest.java
@@ -24,7 +24,7 @@ import java.util.Arrays;
import java.util.List;
/** The PostgresSql params for {@link JdbcDialectTypeTest}. */
-public class PostgresDialectTypeTest extends JdbcDialectTypeTest {
+class PostgresDialectTypeTest extends JdbcDialectTypeTest {
@Override
protected String testDialect() {
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres/table/PostgresDynamicTableSinkITCase.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres/table/PostgresDynamicTableSinkITCase.java
index d0ba3c69..e8c258f1 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres/table/PostgresDynamicTableSinkITCase.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres/table/PostgresDynamicTableSinkITCase.java
@@ -23,5 +23,5 @@ import
org.apache.flink.connector.jdbc.databases.postgres.dialect.PostgresDialec
import org.apache.flink.connector.jdbc.table.JdbcDynamicTableSinkITCase;
/** The Table Sink ITCase for {@link PostgresDialect}. */
-public class PostgresDynamicTableSinkITCase extends JdbcDynamicTableSinkITCase
+class PostgresDynamicTableSinkITCase extends JdbcDynamicTableSinkITCase
implements PostgresTestBase {}
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres/table/PostgresDynamicTableSourceITCase.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres/table/PostgresDynamicTableSourceITCase.java
index 174be59d..1919eb84 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres/table/PostgresDynamicTableSourceITCase.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres/table/PostgresDynamicTableSourceITCase.java
@@ -36,7 +36,7 @@ import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.fiel
import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.tableRow;
/** The Table Source ITCase for {@link PostgresDialect}. */
-public class PostgresDynamicTableSourceITCase extends
JdbcDynamicTableSourceITCase
+class PostgresDynamicTableSourceITCase extends JdbcDynamicTableSourceITCase
implements PostgresTestBase {
@Override
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres/xa/PostgresExactlyOnceSinkE2eTest.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres/xa/PostgresExactlyOnceSinkE2eTest.java
index 38d165d8..97440647 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres/xa/PostgresExactlyOnceSinkE2eTest.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres/xa/PostgresExactlyOnceSinkE2eTest.java
@@ -25,5 +25,5 @@ import
org.apache.flink.connector.jdbc.xa.JdbcExactlyOnceSinkE2eTest;
* A simple end-to-end test for {@link JdbcExactlyOnceSinkE2eTest}. Check for
issues with suspending
* connections (requires pooling) and honoring limits (properly closing
connections).
*/
-public class PostgresExactlyOnceSinkE2eTest extends JdbcExactlyOnceSinkE2eTest
+class PostgresExactlyOnceSinkE2eTest extends JdbcExactlyOnceSinkE2eTest
implements PostgresTestBase {}
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/sqlserver/table/SqlServerDynamicTableSinkITCase.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/sqlserver/table/SqlServerDynamicTableSinkITCase.java
index c2e56a62..99a6a6bf 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/sqlserver/table/SqlServerDynamicTableSinkITCase.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/sqlserver/table/SqlServerDynamicTableSinkITCase.java
@@ -30,7 +30,7 @@ import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.pkFi
import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.tableRow;
/** The Table Sink ITCase for {@link SqlServerDialect}. */
-public class SqlServerDynamicTableSinkITCase extends JdbcDynamicTableSinkITCase
+class SqlServerDynamicTableSinkITCase extends JdbcDynamicTableSinkITCase
implements SqlServerTestBase {
@Override
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/sqlserver/table/SqlServerDynamicTableSourceITCase.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/sqlserver/table/SqlServerDynamicTableSourceITCase.java
index f9444f45..afc178d0 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/sqlserver/table/SqlServerDynamicTableSourceITCase.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/sqlserver/table/SqlServerDynamicTableSourceITCase.java
@@ -40,7 +40,7 @@ import static
org.apache.flink.connector.jdbc.testutils.tables.TableBuilder.tabl
import static org.assertj.core.api.Assertions.assertThatThrownBy;
/** The Table Source ITCase for {@link SqlServerDialect}. */
-public class SqlServerDynamicTableSourceITCase extends
JdbcDynamicTableSourceITCase
+class SqlServerDynamicTableSourceITCase extends JdbcDynamicTableSourceITCase
implements SqlServerTestBase {
@Override
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/sqlserver/xa/SqlServerExactlyOnceSinkE2eTest.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/sqlserver/xa/SqlServerExactlyOnceSinkE2eTest.java
index cfc570c3..12fc1055 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/sqlserver/xa/SqlServerExactlyOnceSinkE2eTest.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/sqlserver/xa/SqlServerExactlyOnceSinkE2eTest.java
@@ -25,5 +25,5 @@ import
org.apache.flink.connector.jdbc.xa.JdbcExactlyOnceSinkE2eTest;
* A simple end-to-end test for {@link JdbcExactlyOnceSinkE2eTest}. Check for
issues with errors on
* closing connections.
*/
-public class SqlServerExactlyOnceSinkE2eTest extends JdbcExactlyOnceSinkE2eTest
+class SqlServerExactlyOnceSinkE2eTest extends JdbcExactlyOnceSinkE2eTest
implements SqlServerTestBase {}
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/sink/AtLeastOnceJdbcSinkTest.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/sink/AtLeastOnceJdbcSinkTest.java
index 3b6cf329..e3a9d28d 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/sink/AtLeastOnceJdbcSinkTest.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/sink/AtLeastOnceJdbcSinkTest.java
@@ -20,7 +20,7 @@ package org.apache.flink.connector.jdbc.sink;
import org.apache.flink.connector.jdbc.JdbcConnectionOptions;
/** Smoke tests for the {@link JdbcSink} and the underlying classes. */
-public class AtLeastOnceJdbcSinkTest extends BaseJdbcSinkTest {
+class AtLeastOnceJdbcSinkTest extends BaseJdbcSinkTest {
@Override
protected <T> JdbcSink<T> finishSink(JdbcSinkBuilder<T> builder) {
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/sink/ExactlyOnceJdbcSinkTest.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/sink/ExactlyOnceJdbcSinkTest.java
index 2ca7ffce..c0a31ea1 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/sink/ExactlyOnceJdbcSinkTest.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/sink/ExactlyOnceJdbcSinkTest.java
@@ -21,7 +21,7 @@ import org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions;
import org.apache.flink.connector.jdbc.JdbcExecutionOptions;
/** Smoke tests for the {@link JdbcSink} and the underlying classes. */
-public class ExactlyOnceJdbcSinkTest extends BaseJdbcSinkTest {
+class ExactlyOnceJdbcSinkTest extends BaseJdbcSinkTest {
@Override
protected <T> JdbcSink<T> finishSink(JdbcSinkBuilder<T> builder) {
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcTablePlanTest.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcTablePlanTest.java
index aa186a40..c342d6ba 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcTablePlanTest.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcTablePlanTest.java
@@ -28,7 +28,7 @@ import org.junit.jupiter.api.TestInfo;
import org.junit.rules.TestName;
/** Plan tests for JDBC connector, for example, testing projection push down.
*/
-public class JdbcTablePlanTest extends TableTestBase {
+class JdbcTablePlanTest extends TableTestBase {
private final StreamTableTestUtil util =
streamTestUtil(TableConfig.getDefault());
diff --git
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkMigrationTest.java
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkMigrationTest.java
index 256fb3f9..01abbd77 100644
---
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkMigrationTest.java
+++
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkMigrationTest.java
@@ -52,7 +52,7 @@ import static
org.apache.flink.streaming.util.OperatorSnapshotUtil.readStateHand
import static
org.apache.flink.streaming.util.OperatorSnapshotUtil.writeStateHandle;
/** Tests state migration for {@link JdbcXaSinkFunction}. */
-public class JdbcXaSinkMigrationTest extends JdbcTestBase {
+class JdbcXaSinkMigrationTest extends JdbcTestBase {
// write a snapshot:
// java <CLASS_NAME> <VERSION>
