wuzexian created FLINK-38045:
--------------------------------
Summary: 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
Reporter: wuzexian
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)
