Yanquan Lv created FLINK-36964:
----------------------------------
Summary: Fix potential exception when SchemaChange in parallel
with Paimon Sink.
Key: FLINK-36964
URL: https://issues.apache.org/jira/browse/FLINK-36964
Project: Flink
Issue Type: New Feature
Components: Flink CDC
Affects Versions: cdc-3.2.1, cdc-3.2.0
Reporter: Yanquan Lv
Fix For: cdc-3.3.0
When assigning bucket number in BucketAssignOperator, SchemaChangeEvent was not
broadcasted to downstream, which may cause the SchemaInfo in PaimonWriter is
not in line with DataChangeEvent.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
