[FLINK-28942][network] Fix the deadlock bug when recycling readers fo…

…r SortMergeResultPartition This closes apache#20560.
liuyongvs · Aug 12, 2022 · f2fb6b2 · f2fb6b2
1 parent 7cf7158
commit f2fb6b2
Showing 1 changed file with 12 additions and 12 deletions.
diff --git a/...src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java b/...src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java
@@ -197,20 +197,20 @@ protected void releaseInternal() {
             if (resultFile == null && fileWriter != null) {
                 fileWriter.releaseQuietly();
             }
+        }
 
-            // delete the produced file only when no reader is reading now
-            readScheduler
-                    .release()
-                    .thenRun(
-                            () -> {
-                                synchronized (lock) {
-                                    if (resultFile != null) {
-                                        resultFile.deleteQuietly();
-                                        resultFile = null;
-                                    }
+        // delete the produced file only when no reader is reading now
+        readScheduler
+                .release()
+                .thenRun(
+                        () -> {
+                            synchronized (lock) {
+                                if (resultFile != null) {
+                                    resultFile.deleteQuietly();
+                                    resultFile = null;
                                 }
-                            });
-        }
+                            }
+                        });
     }
 
     @Override