You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:24:00 UTC

[jira] [Commented] (FLINK-34806) [Feature][Postgres] Support automatically identify newly added tables

    [ https://issues.apache.org/jira/browse/FLINK-34806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828757#comment-17828757 ] 

Flink CDC Issue Import commented on FLINK-34806:
------------------------------------------------

Date: Mon Feb 05 17:36:24 CST 2024, Author: [loserwang1024|https://github.com/loserwang1024]

Great catch! Now debezium version has been upgraded to 1.9.8, maybe we can do some changes and then rebase this PR.

> [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
>
> ### 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)