You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/12/26 08:47:11 UTC
[rocketmq-connect] branch master updated (6b6a6be5 -> 7f9a2203)
This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
from 6b6a6be5 [ISSUE #399]Debezium sopport heartbeat record (#401)
add 7f9a2203 [ISSUE #389]Optimize connector jdbc (#402)
No new revisions were added by this update.
Summary of changes:
connectors/rocketmq-connect-doris/README.txt | 4 +-
connectors/rocketmq-connect-jdbc/README.md | 2 +-
connectors/rocketmq-connect-jdbc/pom.xml | 256 ++++++--------
.../rocketmq-connect-jdbc-core}/pom.xml | 72 ++--
.../connect/jdbc/common/DebeziumTimeTypes.java | 14 -
.../rocketmq/connect/jdbc/common/HeaderField.java | 8 +-
.../jdbc/common/JdbcSourceConfigConstants.java | 0
.../connect/jdbc/config/AbstractConfig.java | 0
.../rocketmq/connect/jdbc/config/ConfigDef.java | 2 +
.../connect/jdbc/dialect/DatabaseDialect.java | 29 +-
.../rocketmq/connect/jdbc/dialect/DropOptions.java | 0
.../jdbc/dialect}/GenericDatabaseDialect.java | 302 +++++++++--------
.../jdbc/dialect/PreparedStatementBinder.java | 58 +++-
.../dialect/provider/CachedConnectionProvider.java | 2 -
.../jdbc/dialect/provider/ConnectionProvider.java | 0
.../connect/jdbc/exception/ConfigException.java | 0
.../exception/TableAlterOrCreateException.java | 0
.../jdbc/schema/column/ColumnDefAdjuster.java | 0
.../jdbc/schema/column/ColumnDefinition.java | 0
.../connect/jdbc/schema/column/ColumnId.java | 2 +-
.../connect/jdbc/schema/db/DbStructure.java | 10 +-
.../connect/jdbc/schema/table/TableDefinition.java | 0
.../jdbc/schema/table/TableDefinitions.java | 0
.../connect/jdbc/schema/table/TableId.java | 0
.../connect/jdbc/sink/BaseSinkConnector.java} | 14 +-
.../rocketmq/connect/jdbc/sink/BaseSinkTask.java} | 60 ++--
.../connect/jdbc/sink/BufferedRecords.java | 219 ++++++++++++
.../connect/jdbc/sink}/JdbcSinkConfig.java | 14 +-
.../rocketmq/connect/jdbc/sink/JdbcWriter.java} | 11 +-
.../connect/jdbc}/sink/RecordValidator.java | 41 ++-
.../connect/jdbc/sink/metadata/FieldsMetadata.java | 9 +-
.../connect/jdbc/sink/metadata/SchemaPair.java | 0
.../jdbc/sink/metadata/SinkRecordField.java | 3 +-
.../connect/jdbc/source/BaseSourceConnector.java} | 20 +-
.../connect/jdbc/source/BaseSourceTask.java} | 19 +-
.../connect/jdbc/source}/JdbcSourceConfig.java | 2 +-
.../connect/jdbc/source}/JdbcSourceTaskConfig.java | 2 +-
.../jdbc/source/TimestampIncrementingCriteria.java | 17 -
.../jdbc/source/metadata/ColumnMapping.java | 0
.../jdbc/source/metadata/SchemaMapping.java | 0
.../jdbc/source/offset/SourceOffsetCompute.java | 7 +-
.../source/offset/TimestampIncrementingOffset.java | 0
.../connect/jdbc/source/querier/BulkQuerier.java | 0
.../connect/jdbc/source/querier/Querier.java | 0
.../querier/TimestampIncrementingQuerier.java | 0
.../rocketmq/connect/jdbc/util/BytesUtil.java | 1 +
.../connect/jdbc/util/ConnectorGroupUtils.java | 0
.../rocketmq/connect/jdbc/util/DateTimeUtils.java | 0
.../connect/jdbc/util/ExpressionBuilder.java | 0
.../connect/jdbc/util/IdentifierRules.java | 0
.../rocketmq/connect/jdbc/util/JdbcDriverInfo.java | 0
.../rocketmq/connect/jdbc/util/NumericMapping.java | 2 +-
.../rocketmq/connect/jdbc/util/QuoteMethod.java | 0
.../rocketmq/connect/jdbc/util/TableType.java | 0
...t.jdbc.dialect.provider.DatabaseDialectProvider | 2 +-
.../connect/jdbc/connector/sink/JdbcSinkTest.java | 0
.../jdbc/connector/sink/OpenMLDBJdbcSinkTest.java | 119 +++++++
.../connector/source/JdbcSourceConnectorTest.java | 0
.../jdbc/connector/source/JdbcSourceTaskTest.java | 4 +-
.../rocketmq-connect-jdbc-mysql}/pom.xml | 30 +-
.../jdbc/mysql/dialect}/MySqlDatabaseDialect.java | 20 +-
.../jdbc/mysql/sink/MysqlJdbcSinkConnector.java} | 22 +-
.../jdbc/mysql/sink/MysqlJdbcSinkTask.java} | 18 +-
.../mysql/source/MysqlJdbcSourceConnector.java} | 16 +-
.../jdbc/mysql/source/MysqlJdbcSourceTask.java} | 24 +-
.../src/main/resources/mysql-jdbc-sink.conf | 18 +
.../src/main/resources/mysql-jdbc-source.conf | 15 +
.../rocketmq-connect-jdbc-openmldb}/pom.xml | 51 ++-
.../openmldb/dialect}/OpenMLDBDatabaseDialect.java | 20 +-
.../openmldb/sink/OpenMLDBJdbcSinkConnector.java} | 16 +-
.../jdbc/openmldb/sink/OpenMLDBJdbcSinkTask.java} | 24 +-
.../src/main/resources/openmldb-jdbc-sink.conf} | 0
.../rocketmq/connect/jdbc/common/Dialect.java | 45 ---
.../rocketmq/connect/jdbc/common/DialectType.java | 25 --
.../rocketmq/connect/jdbc/common/OperatorType.java | 26 --
.../jdbc/dialect/DatabaseDialectFactory.java | 194 -----------
.../dialect/provider/DatabaseDialectProvider.java | 60 ----
.../connect/jdbc/dialect/provider/JdbcUrlInfo.java | 42 ---
.../schema/column/parser/DateColumnParser.java | 61 ----
.../schema/column/parser/TimeColumnParser.java | 63 ----
.../column/parser/TimestampColumnParser.java | 54 ---
.../connect/jdbc/sink/BufferedRecords.java | 377 ---------------------
.../connect/jdbc/sink/RecordValidator.java | 100 ------
.../dialect/DatabaseDialectFactoryTest.java | 16 -
.../jdbc/connector/sink/OpenMLDBJdbcSinkTest.java | 144 --------
.../src/main/resources/avro-sink.template | 2 +-
.../src/main/resources/avro-source.template | 2 +-
.../src/main/resources/json-sink.template | 2 +-
.../src/main/resources/json-source.template | 2 +-
89 files changed, 950 insertions(+), 1866 deletions(-)
copy {rocketmq-connect-sample => connectors/rocketmq-connect-jdbc/rocketmq-connect-jdbc-core}/pom.xml (59%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/common/DebeziumTimeTypes.java (79%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/common/HeaderField.java (84%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/common/JdbcSourceConfigConstants.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/config/AbstractConfig.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/config/ConfigDef.java (99%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialect.java (93%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DropOptions.java (100%)
rename connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/dialect/impl => rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc/dialect}/GenericDatabaseDialect.java (91%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/PreparedStatementBinder.java (72%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/provider/CachedConnectionProvider.java (99%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/provider/ConnectionProvider.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/exception/ConfigException.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/exception/TableAlterOrCreateException.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnDefAdjuster.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnDefinition.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnId.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/schema/db/DbStructure.java (97%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableDefinition.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableDefinitions.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableId.java (100%)
rename connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSinkConnector.java => rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc/sink/BaseSinkConnector.java} (81%)
rename connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSinkTask.java => rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc/sink/BaseSinkTask.java} (77%)
create mode 100644 connectors/rocketmq-connect-jdbc/rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc/sink/BufferedRecords.java
rename connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/connector => rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc/sink}/JdbcSinkConfig.java (97%)
rename connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/sink/Updater.java => rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcWriter.java} (92%)
copy connectors/{rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris => rocketmq-connect-jdbc/rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc}/sink/RecordValidator.java (91%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/FieldsMetadata.java (97%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/SchemaPair.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/SinkRecordField.java (97%)
rename connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnector.java => rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc/source/BaseSourceConnector.java} (89%)
rename connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceTask.java => rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc/source/BaseSourceTask.java} (94%)
rename connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/connector => rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc/source}/JdbcSourceConfig.java (99%)
rename connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/connector => rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc/source}/JdbcSourceTaskConfig.java (96%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/source/TimestampIncrementingCriteria.java (92%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/source/metadata/ColumnMapping.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/source/metadata/SchemaMapping.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/SourceOffsetCompute.java (98%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/TimestampIncrementingOffset.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/BulkQuerier.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/Querier.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/TimestampIncrementingQuerier.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/util/BytesUtil.java (99%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/util/ConnectorGroupUtils.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/util/DateTimeUtils.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/util/IdentifierRules.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/util/JdbcDriverInfo.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/util/NumericMapping.java (96%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/util/QuoteMethod.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/util/TableType.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/main/resources/META-INF/services/org.apache.rocketmq.connect.jdbc.dialect.provider.DatabaseDialectProvider (60%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/test/java/org/apache/rocketmq/connect/jdbc/connector/sink/JdbcSinkTest.java (100%)
create mode 100644 connectors/rocketmq-connect-jdbc/rocketmq-connect-jdbc-core/src/test/java/org/apache/rocketmq/connect/jdbc/connector/sink/OpenMLDBJdbcSinkTest.java
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/test/java/org/apache/rocketmq/connect/jdbc/connector/source/JdbcSourceConnectorTest.java (100%)
rename connectors/rocketmq-connect-jdbc/{ => rocketmq-connect-jdbc-core}/src/test/java/org/apache/rocketmq/connect/jdbc/connector/source/JdbcSourceTaskTest.java (74%)
copy {reporter-api => connectors/rocketmq-connect-jdbc/rocketmq-connect-jdbc-mysql}/pom.xml (87%)
rename connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/dialect/impl => rocketmq-connect-jdbc-mysql/src/main/java/org/apache/rocketmq/connect/jdbc/mysql/dialect}/MySqlDatabaseDialect.java (87%)
copy connectors/{rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BooleanColumnParser.java => rocketmq-connect-jdbc/rocketmq-connect-jdbc-mysql/src/main/java/org/apache/rocketmq/connect/jdbc/mysql/sink/MysqlJdbcSinkConnector.java} (69%)
copy connectors/{rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushAllParser.java => rocketmq-connect-jdbc/rocketmq-connect-jdbc-mysql/src/main/java/org/apache/rocketmq/connect/jdbc/mysql/sink/MysqlJdbcSinkTask.java} (62%)
copy connectors/{rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ScriptParser.java => rocketmq-connect-jdbc/rocketmq-connect-jdbc-mysql/src/main/java/org/apache/rocketmq/connect/jdbc/mysql/source/MysqlJdbcSourceConnector.java} (69%)
copy connectors/{rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AppendParser.java => rocketmq-connect-jdbc/rocketmq-connect-jdbc-mysql/src/main/java/org/apache/rocketmq/connect/jdbc/mysql/source/MysqlJdbcSourceTask.java} (61%)
create mode 100644 connectors/rocketmq-connect-jdbc/rocketmq-connect-jdbc-mysql/src/main/resources/mysql-jdbc-sink.conf
create mode 100644 connectors/rocketmq-connect-jdbc/rocketmq-connect-jdbc-mysql/src/main/resources/mysql-jdbc-source.conf
copy connectors/{rocketmq-connect-debezium/rocketmq-connect-debezium-mongodb => rocketmq-connect-jdbc/rocketmq-connect-jdbc-openmldb}/pom.xml (85%)
rename connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/dialect/impl => rocketmq-connect-jdbc-openmldb/src/main/java/org/apache/rocketmq/connect/jdbc/openmldb/dialect}/OpenMLDBDatabaseDialect.java (88%)
copy connectors/{rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ScriptParser.java => rocketmq-connect-jdbc/rocketmq-connect-jdbc-openmldb/src/main/java/org/apache/rocketmq/connect/jdbc/openmldb/sink/OpenMLDBJdbcSinkConnector.java} (69%)
copy connectors/{rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AppendParser.java => rocketmq-connect-jdbc/rocketmq-connect-jdbc-openmldb/src/main/java/org/apache/rocketmq/connect/jdbc/openmldb/sink/OpenMLDBJdbcSinkTask.java} (60%)
copy connectors/{rocketmq-connect-debezium/README.md => rocketmq-connect-jdbc/rocketmq-connect-jdbc-openmldb/src/main/resources/openmldb-jdbc-sink.conf} (100%)
delete mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/Dialect.java
delete mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/DialectType.java
delete mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/OperatorType.java
delete mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialectFactory.java
delete mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/provider/DatabaseDialectProvider.java
delete mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/provider/JdbcUrlInfo.java
delete mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/parser/DateColumnParser.java
delete mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/parser/TimeColumnParser.java
delete mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/parser/TimestampColumnParser.java
delete mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/BufferedRecords.java
delete mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/RecordValidator.java
delete mode 100644 connectors/rocketmq-connect-jdbc/src/test/java/org/apache/rocketmq/connect/jdbc/connector/dialect/DatabaseDialectFactoryTest.java
delete mode 100644 connectors/rocketmq-connect-jdbc/src/test/java/org/apache/rocketmq/connect/jdbc/connector/sink/OpenMLDBJdbcSinkTest.java