[tiering] Use exponential delay restart strategy for Flink tiering job

[Shawn-Hx]

Configure the stateless tiering job to retry indefinitely when checkpointing is disabled, preventing transient failures from terminating the job permanently.

Move the failover integration test to fluss-flink-tiering so that it covers the production job configuration.

Purpose

Linked issue: close #3681

Brief change log

Tests

TieringFailoverITCase

• Verifies that checkpointing is disabled.
• Injects two consecutive lake write failures.
• Verifies that the job recovers and continues tiering data correctly.

API and Format

No public API or storage format changes.

Documentation

No documentation changes are required.

[Copilot]

Pull request overview

This PR updates the Flink tiering job entrypoint to use a fixed-delay restart strategy (to avoid Flink’s default no-restart behavior when checkpointing is disabled) and adjusts tiering failover integration testing so it exercises the production entrypoint’s StreamExecutionEnvironment configuration.

Changes:

• Configure FlussLakeTiering to use Flink’s fixed-delay restart strategy with effectively unlimited restart attempts.
• Update TieringFailoverITCase to build its StreamExecutionEnvironment via FlussLakeTiering, inject two consecutive lake write failures, and avoid canceling an already-finished job.
• Remove checkpoint enabling from the shared tiering IT base and add needed test dependencies to the tiering module.

Reviewed changes

Copilot reviewed 4 out of 4 changed files in this pull request and generated 1 comment.

File	Description
fluss-flink/fluss-flink-tiering/src/test/java/org/apache/fluss/flink/tiering/TieringFailoverITCase.java	Reworks failover IT to use the production entrypoint’s exec env and validates recovery from consecutive write failures.
fluss-flink/fluss-flink-tiering/src/main/java/org/apache/fluss/flink/tiering/FlussLakeTiering.java	Adds fixed-delay restart strategy configuration for stateless tiering jobs when checkpoints are disabled.
fluss-flink/fluss-flink-tiering/pom.xml	Adds test-scoped dependencies needed to run tiering ITs in the tiering module.
fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/tiering/FlinkTieringTestBase.java	Aligns tiering IT base with production by no longer enabling checkpointing by default.

Comments suppressed due to low confidence (1)

fluss-flink/fluss-flink-tiering/src/test/java/org/apache/fluss/flink/tiering/TieringFailoverITCase.java:75

• This test bootstraps the ExecutionEnvironment via FlussLakeTiering, but passes --datalake.format as Paimon while the actual tiering job built in FlinkTieringTestBase is hard-coded to use DataLakeFormat.LANCE.toString() (see FlinkTieringTestBase#buildTieringJob). Using LANCE here keeps the test configuration consistent and avoids masking format-specific behavior in FlussLakeTiering initialization.

---

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.