apache / apache/seatunnel

[Feature][seatunnel core][seatunnel-flink-start] Filnk engine supports task restore from checkpoint upon startup

Open
#10,220 5 comments 0 reactions 0 assignees View on GitHub
Dominant language
Java
Stars
9.7k
Forks
2.4k
Avg merge
3d 9h
Merged PRs (30d)
204

Description

### Search before asking

- [x] I had searched in the [feature](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22Feature%22) and found no similar feature requirement.

### Description

For the Zeta engine, restore can be done from jobId, and for the Flink engine, we should also support restore from checkpoint . If support is needed, I will submit the code

### Usage Scenario

_No response_

### Related issues

_No response_

### Are you willing to submit a PR?

- [x] Yes I am willing to submit a PR!

### Code of Conduct

- [x] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)

Contributor guide

No contributing guide indexed for this repository

Research direction

Start by locating the seatunnel-flink-start module and reading how startup currently handles jobs and checkpoints. Confirm the expected restore behavior for a Flink task on startup, then verify that a task can resume from its checkpoint without breaking the existing Zeta-engine behavior.

Written by the indexing model from the issue text.

Assessment

Tech stack
java
Domain
data-engineering, distributed-systems
Issue type
Feature
Difficulty
4/5
Estimated time
3-5 days
Activity status
Stale
Clarity
Needs clarification
Newbie friendliness
35/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.