yux created FLINK-36763:
---------------------------
Summary: Support schema inference and evolution with
single-table-mutliple-partition sources
Key: FLINK-36763
URL: https://issues.apache.org/jira/browse/FLINK-36763
Project: Flink
Issue Type: Bug
Components: Flink CDC
Reporter: yux
Current schema evolution implementation implicitly assumes that there can't be
two partitions with the same TableID being consumed on different subTasks. This
is not always true for some weak-structured sources like Kafka and MongoDB,
where table schemas are not centralized and might evolve independently in
various parallelized tasks.
It's very unlikely to be a trivial change, and might involves modifying most
part of pipeline implementation.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
