apache/seatunnel

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

Open

#10.353 aberto em 16 de jan. de 2026

Ver no GitHub
 (9 comments) (4 reactions) (1 assignee)Java (1.432 forks)batch import
help wanted

Métricas do repositório

Stars
 (6.897 stars)
Métricas de merge de PR
 (Mesclagem média 13d 21h) (143 fundiu PRs em 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.

Guia do colaborador

Direção de pesquisa
Investigue a versão atual da dependência do Flink no SeaTunnel e as alterações necessárias para atualizar para o Flink 2.0.1, incluindo mudanças na API e ajustes de compatibilidade.
Pilha de tecnologia
java
Domain
backend
Tipo Issue
Funcionalidade
DifficultyDificuldade de implementação estimada para um novo contribuidor, de 1 para alterações muito pequenas a 5 para trabalho de nível especializado.
2
Tempo estimadoUm intervalo de tempo aproximado para um colaborador experiente investigar, implementar, testar e preparar um pull request.
1-2 dias
Status da atividadeQuão disponível o issue aparece agora: novo, ativo, obsoleto, bloqueado ou aguardando entrada do mantenedor.
Ativo
ClarityCom que clareza o issue explica a mudança esperada, os critérios de aceitação e a próxima etapa.
Claro
Prerequisites
JavaApache Flink
Simpatia para novatosUma pontuação de 1 a 100 que estima o quão acessível este issue é para colaboradores iniciantes.
40