Skip to content

Commit f2fb6b2

Browse files
authored
[FLINK-28942][network] Fix the deadlock bug when recycling readers for SortMergeResultPartition
This closes apache#20560.
1 parent 7cf7158 commit f2fb6b2

File tree

1 file changed

+12
-12
lines changed

1 file changed

+12
-12
lines changed

flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java

+12-12
Original file line numberDiff line numberDiff line change
@@ -197,20 +197,20 @@ protected void releaseInternal() {
197197
if (resultFile == null && fileWriter != null) {
198198
fileWriter.releaseQuietly();
199199
}
200+
}
200201

201-
// delete the produced file only when no reader is reading now
202-
readScheduler
203-
.release()
204-
.thenRun(
205-
() -> {
206-
synchronized (lock) {
207-
if (resultFile != null) {
208-
resultFile.deleteQuietly();
209-
resultFile = null;
210-
}
202+
// delete the produced file only when no reader is reading now
203+
readScheduler
204+
.release()
205+
.thenRun(
206+
() -> {
207+
synchronized (lock) {
208+
if (resultFile != null) {
209+
resultFile.deleteQuietly();
210+
resultFile = null;
211211
}
212-
});
213-
}
212+
}
213+
});
214214
}
215215

216216
@Override

0 commit comments

Comments
 (0)