[hotfix] Simplify the lambda expression in TaskManagerRunner

spotify · Jun 24, 2020 · b5e5063 · b5e5063
1 parent e716293
commit b5e5063
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java
@@ -268,9 +268,7 @@ public void onFatalError(Throwable exception) {
  FutureUtils.orTimeout(terminationFuture, FATAL_ERROR_SHUTDOWN_TIMEOUT_MS, TimeUnit.MILLISECONDS);
 
  terminationFuture.whenComplete(
- (Void ignored, Throwable throwable) -> {
- terminateJVM();
- });
+ (Void ignored, Throwable throwable) -> terminateJVM());
  }
  }