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 12fb98ebe15ab8e1e18d270eb771b1b04c645639 Author: Matthias Pohl <[email protected]> AuthorDate: Wed Dec 8 12:30:41 2021 +0100 [hotfix] Refactors nested if statements --- .../org/apache/flink/runtime/dispatcher/Dispatcher.java | 16 ++++++---------- 1 file changed, 6 insertions(+), 10 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java b/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java index d875be5..240ced5 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java @@ -497,17 +497,13 @@ public abstract class Dispatcher extends PermanentlyFencedRpcEndpoint<Dispatcher private CleanupJobState handleJobManagerRunnerResult( JobManagerRunnerResult jobManagerRunnerResult, ExecutionType executionType) { - if (jobManagerRunnerResult.isInitializationFailure()) { - if (executionType == ExecutionType.RECOVERY) { - return jobManagerRunnerFailed( - jobManagerRunnerResult.getExecutionGraphInfo().getJobId(), - jobManagerRunnerResult.getInitializationFailure()); - } else { - return jobReachedTerminalState(jobManagerRunnerResult.getExecutionGraphInfo()); - } - } else { - return jobReachedTerminalState(jobManagerRunnerResult.getExecutionGraphInfo()); + if (jobManagerRunnerResult.isInitializationFailure() + && executionType == ExecutionType.RECOVERY) { + return jobManagerRunnerFailed( + jobManagerRunnerResult.getExecutionGraphInfo().getJobId(), + jobManagerRunnerResult.getInitializationFailure()); } + return jobReachedTerminalState(jobManagerRunnerResult.getExecutionGraphInfo()); } enum CleanupJobState {
