Skip to content

[Feature][Zeta] Unify checkpoint and savepoint restore handling - #11841

Open
JeremyXin wants to merge 3 commits into
apache:devfrom
JeremyXin:feat-unify-checkpoint-restore-param
Open

[Feature][Zeta] Unify checkpoint and savepoint restore handling#11841
JeremyXin wants to merge 3 commits into
apache:devfrom
JeremyXin:feat-unify-checkpoint-restore-param

Conversation

@JeremyXin

Copy link
Copy Markdown
Contributor

Purpose of this pull request

What does this PR do

  • Use restoreMode as the primary restore signal in Zeta restore flow
  • Prevent checkpoint restore from following savepoint-only submission and cleanup logic

Why is this needed

  • Legacy savepoint flags and restore-mode semantics were mixed in several paths
  • This could cause inconsistent restore behavior, especially for checkpoint restore

Does this PR introduce any user-facing change?

How was this patch tested?

Check list

Route restore decisions through restoreMode so checkpoint restore no longer inherits savepoint-only cleanup and submission behavior.

Constraint: Preserve legacy submitJob flag and JobImmutableInformation wire compatibility while fixing restore semantics
Rejected: Remove or rename isStartWithSavePoint now | would break compatibility paths and current callers
Confidence: medium
Scope-risk: narrow
Directive: Use restoreMode or isRestoreJob for new restore logic; keep legacy savepoint flag compatibility-only
Tested: ./mvnw -pl seatunnel-engine -am spotless:apply -DskipTests
Tested: ./mvnw -f seatunnel-engine/seatunnel-engine-core/pom.xml -Dtest=JobImmutableInformationCompatibilityTest -DfailIfNoTests=false test
Not-tested: ./mvnw -pl seatunnel-engine/seatunnel-engine-core,seatunnel-engine/seatunnel-engine-server -am -Dtest=JobImmutableInformationCompatibilityTest,CoordinatorServiceJobCleanupTest -DfailIfNoTests=false test | blocked by unrelated seatunnel-common test compilation errors
Not-tested: ./mvnw -f seatunnel-engine/seatunnel-engine-server/pom.xml -Dtest=CoordinatorServiceJobCleanupTest -DfailIfNoTests=false test | blocked by sandbox port-bind restriction for Hazelcast
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant