linqigeng created FLINK-36326:
---------------------------------
Summary: Newly added table failed in mysql pipeline connector
Key: FLINK-36326
URL: https://issues.apache.org/jira/browse/FLINK-36326
Project: Flink
Issue Type: Bug
Components: Flink CDC
Affects Versions: cdc-3.2.0
Reporter: linqigeng
Attachments: image-2024-09-19-16-55-03-082.png
When mysql source added a newly table then restart flink cdc pipeline job would
cause this exception:
!image-2024-09-19-16-55-03-082.png!
pipeline def:
{code:java}
source:
type: mysql
name: MySQL Source
hostname: localhost
port: 3306
username: root
password: root
tables: test_db.\.*
server-id: 40000-40002
jdbc.properties.tinyInt1isBit: false
jdbc.properties.zeroDateTimeBehavior: convertToNull
scan.newly-added-table.enabled: true
sink:
type: doris
fenodes: localhost:8030
username: root
password: root
pipeline:
name: MySQL to Doris Pipeline
parallelism: 1{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
