[
https://issues.apache.org/jira/browse/FLINK-38045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv resolved FLINK-38045.
--------------------------------
Resolution: Fixed
Fixed in master via d0fe46cb6f9aa61fda227f1968a8f8f008ecca45.
> Refactor: Make transform operator stateless by building a
> createTableEventCache
> -------------------------------------------------------------------------------
>
> Key: FLINK-38045
> URL: https://issues.apache.org/jira/browse/FLINK-38045
> Project: Flink
> Issue Type: Improvement
> Affects Versions: cdc-3.4.0
> Reporter: wuzexian
> Assignee: wuzexian
> Priority: Major
> Labels: pull-request-available
> Fix For: cdc-3.5.0
>
>
> For historical reasons, the current implementation does not utilize the
> Source to build a schema cache. This requires the {{TransformOperator}} to
> maintain its own complex state.
> An optimization is proposed: to build a reusable schema cache at the Source
> (or in an operator immediately following it).
> The primary benefit of this approach is that the {{transform operator}} can
> be made completely stateless. This simplifies its design, improves
> architectural modularity, and makes the entire pipeline more robust and
> maintainable.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
