apache/seatunnel

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

Open

#10 353 ouverte le 16 janv. 2026

Voir sur GitHub
 (9 commentaires) (4 réactions) (1 assigné)Java (1 432 forks)batch import
help wanted

Métriques du dépôt

Stars
 (6 897 stars)
Métriques de merge PR
 (Merge moyen 13j 21h) (143 PRs mergées en 30 j)

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.

Guide contributeur