Flink CDC Issue Import created FLINK-34806:
----------------------------------------------
Summary: [Feature][Postgres] Support automatically identify newly
added tables
Key: FLINK-34806
URL: https://issues.apache.org/jira/browse/FLINK-34806
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Reporter: Flink CDC Issue Import
### Search before asking
- [X] I searched in the
[issues|https://github.com/ververica/flink-cdc-connectors/issues] and found
nothing similar.
### Motivation
When we start a job with a regular expression, if a new table name matches the
regular expression and is created, the event emitted by the table will not be
captured and IllegalArgumentException will be thrown, causing the entire flash
job to fail over.
### Solution
When instantiating EventDispatcher, InconsistenceSchemaHandler is passed in,
and all internal schema information is refreshed at this time.
### Alternatives
_No response_
### Anything else?
_No response_
### Are you willing to submit a PR?
- [X] I'm willing to submit a PR!
---------------- Imported from GitHub ----------------
Url: https://github.com/apache/flink-cdc/issues/2397
Created by: [TyrantLucifer|https://github.com/TyrantLucifer]
Labels: enhancement,
Created at: Tue Aug 15 19:35:17 CST 2023
State: open
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
