[
https://issues.apache.org/jira/browse/FLINK-37585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941499#comment-17941499
]
Xin Gong commented on FLINK-37585:
----------------------------------
You can see this discussion
[https://github.com/apache/flink-cdc/discussions/3338.]
> The data of the newly added table cannot be read
> ------------------------------------------------
>
> Key: FLINK-37585
> URL: https://issues.apache.org/jira/browse/FLINK-37585
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Affects Versions: cdc-3.2.1
> Reporter: jeff-zou
> Priority: Major
> Labels: pull-request-available
>
> After starting Flink CDC, when a new table is created in MySQL, Flink can
> read the table structure of this table, but cannot read the data in it.
>
> The method to reproduce the bug as follows:
> 1.Start Flink CDC for sync Mysql
> {code:java}
> // code placeholder
> MySqlSource<String> mySqlSource =
> MySqlSource.<String>builder()
> .port(3306)
> .hostname("10.11.69.176")
> .port(3306)
> .databaseList("cdc")
> .tableList(".*")
> .username("test")
> .password("123456")
> .serverTimeZone("UTC")
> .deserializer(new JsonDebeziumDeserializationSchema())
> .includeSchemaChanges(true)
> .serverId("5401-5404")
> .scanNewlyAddedTableEnabled(true)
> .debeziumProperties(properties)
> .fetchSize(1024)
> .connectTimeout(Duration.ofSeconds(30))
> .build();
> .......................
> {code}
> 2. Create table in Mysql
> {code:java}
> // code placeholder
> CREATE TABLE `test` (
> `id` varchar(100),
> PRIMARY KEY (`id`)
> ) {code}
> 3. Write data to Mysql
> {code:java}
> // code placeholder
> INSERT INTO test(`id`) VALUES('kkkkkk') ;
> {code}
>
>
> Flink can read the table's schema, but cannot read the data 'kkkkkk' in it.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
