[
https://issues.apache.org/jira/browse/FLINK-37712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-37712:
----------------------------------
Assignee: Yanquan Lv
> Met TableNotFound exception when reading ParallelMetadataSource to Paimon Sink
> ------------------------------------------------------------------------------
>
> Key: FLINK-37712
> URL: https://issues.apache.org/jira/browse/FLINK-37712
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Affects Versions: cdc-3.4.0
> Reporter: Yanquan Lv
> Assignee: Yanquan Lv
> Priority: Minor
>
> when using ParallelMetadataSource as Source, the Flink topology will be like:
> ---> 1. Source
> ---> 2. PreTransform
> ---> 3. PostTransform
> ---> 4. Partitioning
> ---> 5. Schema Operator
> ---> 6. Sink
> In Partitioning, the table may not be created.
> However, the PaimonHashFunction used catalog to obtain table information for
> calculation, therefore, an error occurred where the table does not exist.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
