From 2a89c3011bed056fc6153eea5191c563980855fe Mon Sep 17 00:00:00 2001 From: jiaoqingbo <1178404354@qq.com> Date: Mon, 5 Feb 2024 13:57:52 +0800 Subject: [PATCH] [CELEBORN-1244] Delete redundant remove operations and handle timeout requests in final check ### What changes were proposed in this pull request? Delete redundant remove operations and handle timeout requests in final check ### Why are the changes needed? Delete redundant remove operations and handle timeout requests in final check ### Does this PR introduce _any_ user-facing change? NO ### How was this patch tested? PASS GA Closes #2251 from jiaoqingbo/CELEBORN-1244. Authored-by: jiaoqingbo <1178404354@qq.com> Signed-off-by: SteNicholas --- .../scala/org/apache/celeborn/client/commit/CommitHandler.scala | 1 - 1 file changed, 1 deletion(-) diff --git a/client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala b/client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala index 632d407da8..59cf446415 100644 --- a/client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala +++ b/client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala @@ -357,7 +357,6 @@ abstract class CommitHandler( logError( s"Ask worker($worker) CommitFiles for $shuffleId failed because of Timeout" + s" (attempt ${status.retriedTimes}/$maxRetries), will not retry.") - iter.remove() } } }