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

Posted to issues@flink.apache.org by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/06/24 08:32:00 UTC

[jira] [Assigned] (FLINK-35647) Pipeline route rule supports placeholder replacement

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

Ruan Hang reassigned FLINK-35647:
---------------------------------

    Assignee: yux

> Pipeline route rule supports placeholder replacement
> ----------------------------------------------------
>
>                 Key: FLINK-35647
>                 URL: https://issues.apache.org/jira/browse/FLINK-35647
>             Project: Flink
>          Issue Type: Improvement
>          Components: Flink CDC
>            Reporter: yux
>            Assignee: yux
>            Priority: Major
>
> Currently, we must provide explicit sink-table in pipeline route rules, which means if we'd like to route all tables in specific database and change names in pattern, there's no choice but write all rules separately, which is a chore.
> There's already an implementation ([https://github.com/apache/flink-cdc/pull/2908)] to use some placeholder syntax like (db.source<> -> db.sink<>) to perform replacement in batch, which could solve this problem.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)