Vinh Pham created FLINK-37479: --------------------------------- Summary: postgres cdc connector support discover PARTITIONED TABLE Key: FLINK-37479 URL: https://issues.apache.org/jira/browse/FLINK-37479 Project: Flink Issue Type: Improvement Components: Flink CDC Reporter: Vinh Pham
At the moment, Postgresql connector doesn't support discover PARTITIONED TABLE, making it the connector not possible to take snapshot on partitioned table. https://github.com/apache/flink-cdc/blob/master/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/utils/TableDiscoveryUtils.java#L41 -- This message was sent by Atlassian Jira (v8.20.10#820010)