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

Xiqian Yu resolved FLINK-34806.
-------------------------------
    Fix Version/s: cdc-3.7.0
         Assignee: Hongshun Wang
       Resolution: Fixed

Merged into master via aa42119effe6a2ffa1aa85c6ff781d44cc2e18e9.

> [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
>            Assignee: Hongshun Wang
>            Priority: Major
>              Labels: github-import, pull-request-available
>             Fix For: cdc-3.7.0
>
>
> ### 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