Search before asking
What happened
Problem
After the merge of #9867, the SupportSchemaEvolutionSinkWriter interface contains Flink-specific methods (e.g., handleFlushEvent, getSchemaCoordinator). The implementation details of a particular engine should not be introduced into the general API.
Solution
Refactor to decouple the API:
- Keep only generic methods (like
applySchemaChange) in the SupportSchemaEvolutionSinkWriter interface.
- Move all Flink-specific logic (flush coordination,
SchemaCoordinator interaction) into the FlinkSinkWriter implementation.
Related PR
SeaTunnel Version
SeaTunnel Config
Running Command
Error Exception
Zeta or Flink or Spark Version
No response
Java or Scala Version
No response
Screenshots
No response
Are you willing to submit PR?
Code of Conduct