This is an automated email from the ASF dual-hosted git repository.
gongzhongqiang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
from 47e5cd6d8 [hotfix][pipeline-connector][maxcompute] Fix MaxCompute
Pipeline Connector tests by upgrading maxcompute-emulator
add 9ad071c1f [FLINK-36282][pipeline-connector][cdc-connector][mysql]fix
incorrect data type of TINYINT(1) in mysql pipeline connector (#3608)
No new revisions were added by this update.
Summary of changes:
.../docs/connectors/pipeline-connectors/mysql.md | 7 ++
docs/content.zh/docs/faq/faq.md | 13 ++++
.../docs/connectors/pipeline-connectors/mysql.md | 7 ++
docs/content/docs/faq/faq.md | 13 ++++
.../mysql/factory/MySqlDataSourceFactory.java | 11 ++-
.../connectors/mysql/source/MySqlDataSource.java | 3 +-
.../mysql/source/MySqlDataSourceOptions.java | 7 ++
.../mysql/source/MySqlEventDeserializer.java | 18 ++++-
.../parser/CustomAlterTableParserListener.java | 11 ++-
.../source/parser/CustomMySqlAntlrDdlParser.java | 6 +-
.../parser/CustomMySqlAntlrDdlParserListener.java | 7 +-
.../source/reader/MySqlPipelineRecordEmitter.java | 3 +-
.../connectors/mysql/utils/MySqlSchemaUtils.java | 12 +--
.../cdc/connectors/mysql/utils/MySqlTypeUtils.java | 10 ++-
.../mysql/source/MySqlMetadataAccessorITCase.java | 50 ++++++++----
.../mysql/source/MySqlPipelineITCase.java | 88 +++++++++++++++++++++-
.../mysql/debezium/reader/BinlogSplitReader.java | 3 +-
.../connectors/mysql/schema/MySqlTypeUtils.java | 10 ++-
.../mysql/source/assigners/MySqlChunkSplitter.java | 10 ++-
.../mysql/source/config/MySqlSourceConfig.java | 9 ++-
.../source/config/MySqlSourceConfigFactory.java | 9 ++-
.../connectors/mysql/source/utils/ChunkUtils.java | 10 ++-
.../assigners/MySqlSnapshotSplitAssignerTest.java | 2 +-
23 files changed, 259 insertions(+), 60 deletions(-)
