apache/seatunnel

[Improve][Core] Support for Apache Flink 2.x

Open

#10,353 opened on Jan 16, 2026

View on GitHub
 (9 comments) (4 reactions) (1 assignee)Java (1,432 forks)batch import
help wanted

Repository metrics

Stars
 (6,897 stars)
PR merge metrics
 (Avg merge 13d 21h) (143 merged PRs in 30d)

Description

Hello,

I would like to propose adding support for Apache Flink 2.0.1 in SeaTunnel.

Background

Apache Flink 2.0 was released on March 24, 2025, and we anticipate that many organizations will consider upgrading to this version. For instance, users may want to leverage new features such as per-topic scan parallelism configuration in Kafka source connectors, which would require a version upgrade.

Proposal

To enable a smooth transition for SeaTunnel users who wish to adopt Flink 2.0, I suggest adding official support for Apache Flink 2.0.1 in SeaTunnel. This would allow users to take advantage of new Flink features without compatibility concerns.

Request

If this aligns with the project's roadmap, would I be able to contribute and develop this feature? I would be happy to submit a pull request for this enhancement.

Thank you for considering this request.

Contributor guide