(flink-cdc) branch master updated (47e5cd6d8 -> 9ad071c1f)

[go...@apache.org]

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(-)