Skip to content

[Bug][Flink] Move Flink-specific flush coordination from API to translation layer #9980

@CloverDew

Description

@CloverDew

Search before asking

  • I had searched in the issues and found no similar issues.

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:

  1. Keep only generic methods (like applySchemaChange) in the SupportSchemaEvolutionSinkWriter interface.
  2. 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?

  • Yes I am willing to submit a PR!

Code of Conduct

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions