[flink] branch release-1.14 updated: [FLINK-24401][runtime] Fix the bug of TM cannot exit after Metaspace OOM

[pnowojski]

This is an automated email from the ASF dual-hosted git repository.

pnowojski pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.14 by this push:
     new 8f73e6c  [FLINK-24401][runtime] Fix the bug of TM cannot exit after 
Metaspace OOM
8f73e6c is described below

commit 8f73e6c38cc4b9174cffca29ab3bf33ddfbdc3ed
Author: fanrui <1996fan...@gmail.com>
AuthorDate: Thu Nov 4 15:24:53 2021 +0800

    [FLINK-24401][runtime] Fix the bug of TM cannot exit after Metaspace OOM
---
 .../org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java   | 7 +------
 1 file changed, 1 insertion(+), 6 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
index 7efd166..42a9a66 100644
--- 
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
@@ -331,12 +331,7 @@ public class TaskManagerRunner implements 
FatalErrorHandler {
                 "Fatal error occurred while executing the TaskManager. 
Shutting it down...",
                 exception);
 
-        // In case of the Metaspace OutOfMemoryError, we expect that the 
graceful shutdown is
-        // possible,
-        // as it does not usually require more class loading to fail again 
with the Metaspace
-        // OutOfMemoryError.
-        if (ExceptionUtils.isJvmFatalOrOutOfMemoryError(exception)
-                && !ExceptionUtils.isMetaspaceOutOfMemoryError(exception)) {
+        if (ExceptionUtils.isJvmFatalOrOutOfMemoryError(exception)) {
             terminateJVM();
         } else {
             closeAsync(Result.FAILURE);