Skip to content

[FLINK-39879][tests] Avoid deploy RPC timeout in CheckpointAcknowledgeFailureITCase #28377

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
MartijnVisser wants to merge 1 commit into
base: master
Choose a base branch
from
Open

[FLINK-39879][tests] Avoid deploy RPC timeout in CheckpointAcknowledgeFailureITCase #28377

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 5 additions & 2 deletions ...src/test/java/org/apache/flink/test/checkpointing/CheckpointAcknowledgeFailureITCase.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -68,8 +68,11 @@ public class CheckpointAcknowledgeFailureITCase extends TestLogger {
// let all the state go via checkpoint ACK RPC to exceed frame size limit
private static final MemorySize IN_MEM_STATE_THRESHOLD = new MemorySize(STATE_SIZE * 2);

// let pekko time out checkpoint ACK
private static final Duration ASK_TIMEOUT = Duration.ofMillis(250);
// The oversized checkpoint ACK exceeds the pekko frame size, so it can never be delivered and
// always surfaces as an AskTimeoutException; this ask timeout only controls how quickly that
// surfaces, not whether the ACK fails. Because it is the cluster-wide RPC timeout it also
// covers task deployment, so keep it large enough that deployment does not time out on slow CI.
private static final Duration ASK_TIMEOUT = Duration.ofSeconds(1);
// do NOT let flink time out the checkpoint
private static final Duration CHECKPOINT_TIMEOUT = ASK_TIMEOUT.multipliedBy(1000);

Expand Down