[
https://issues.apache.org/jira/browse/FLINK-37114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hql0312 updated FLINK-37114:
----------------------------
Description:
PostgresSourceBuilder postgresSourceBuilder =
PostgresSourceBuilder.PostgresIncrementalSource.builder()
.tableList("test\.t_(.*)");
when table is regular expression, and match too many tables, Source will load
all match table's columns , index, primary for each table chunk phase, actually
only the context tableId should load.
was:
PostgresSourceBuilder postgresSourceBuilder =
PostgresSourceBuilder.PostgresIncrementalSource.builder()
.tableList("test\.t_(.*)");
when table is regular expression, and match too many tables, Source will load
all match table's columns , index, primary for each table chunk phase, actually
only the conext tableId should load.
> Flink CDC Postgres Connector subsribe regular expression will be slow
> ---------------------------------------------------------------------
>
> Key: FLINK-37114
> URL: https://issues.apache.org/jira/browse/FLINK-37114
> Project: Flink
> Issue Type: Bug
> Reporter: hql0312
> Priority: Major
>
> PostgresSourceBuilder postgresSourceBuilder =
> PostgresSourceBuilder.PostgresIncrementalSource.builder()
> .tableList("test\.t_(.*)");
> when table is regular expression, and match too many tables, Source will load
> all match table's columns , index, primary for each table chunk phase,
> actually only the context tableId should load.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
