yangyu created FLINK-38276:
------------------------------
Summary: PaimonWriter does not invalidate cache when schema changes
Key: FLINK-38276
URL: https://issues.apache.org/jira/browse/FLINK-38276
Project: Flink
Issue Type: Bug
Components: Flink CDC
Reporter: yangyu
In org.apache.flink.cdc.connectors.paimon.sink.v2.PaimonWriter, when a
SchemaChangeEvent is received,it does not invoke invalidateCache in
org.apache.paimon.catalog.Catalog. If CachingCatalog is used, this may result
in fetching an outdated schema from the cache.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
