This is an automated email from the ASF dual-hosted git repository. mapohl pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 77da0414929437687d7c19df18200a2528b6c27c Author: Zdenek Tison <[email protected]> AuthorDate: Fri Sep 6 08:26:38 2024 +0200 [hotfix] Added ExecutionGraph validation while transiting to WaitingForResources state in RestartingTest --- .../apache/flink/runtime/scheduler/adaptive/RestartingTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/RestartingTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/RestartingTest.java index 77d9c8a2373..346f09b00eb 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/RestartingTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/RestartingTest.java @@ -191,7 +191,7 @@ class RestartingTest { private final StateValidator<ExecutingTest.CancellingArguments> cancellingStateValidator = new StateValidator<>("Cancelling"); - private final StateValidator<Void> waitingForResourcesStateValidator = + private final StateValidator<ExecutionGraph> waitingForResourcesStateValidator = new StateValidator<>("WaitingForResources"); private final StateValidator<ExecutionGraph> creatingExecutionGraphStateValidator = @@ -202,7 +202,7 @@ class RestartingTest { } public void setExpectWaitingForResources() { - waitingForResourcesStateValidator.expectInput((none) -> {}); + waitingForResourcesStateValidator.expectInput(assertNonNull()); } public void setExpectCreatingExecutionGraph() { @@ -225,8 +225,8 @@ class RestartingTest { public void archiveFailure(RootExceptionHistoryEntry failure) {} @Override - public void goToWaitingForResources(ExecutionGraph previousExecutionGraph) { - waitingForResourcesStateValidator.validateInput(null); + public void goToWaitingForResources(@Nullable ExecutionGraph previousExecutionGraph) { + waitingForResourcesStateValidator.validateInput(previousExecutionGraph); hadStateTransition = true; }
