[ 
https://issues.apache.org/jira/browse/FLINK-34806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

ASF GitHub Bot updated FLINK-34806:
-----------------------------------
    Labels: github-import pull-request-available  (was: github-import)

> [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
>            Priority: Major
>              Labels: github-import, pull-request-available
>
> ### 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)

Reply via email to