[ https://issues.apache.org/jira/browse/FLINK-38045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Leonard Xu reassigned FLINK-38045: ---------------------------------- Assignee: wuzexian > 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 > Assignee: wuzexian > Priority: Major > > 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)