proletarians opened a new pull request, #4056: URL: https://github.com/apache/flink-cdc/pull/4056
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 is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
