This is an automated email from the ASF dual-hosted git repository. ethanfeng pushed a commit to branch branch-0.2 in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git
commit 1d5137d92c636ba5b13c54d0952fa32c4d163134 Author: Ethan Feng <[email protected]> AuthorDate: Mon Feb 20 21:45:37 2023 +0800 [CELEBORN-308] Fix flusher will exit unexpectedly if flush task write failed. (#1249) (cherry picked from commit 26a3bb5e72971256028b33daefccaedc9e3ce04d) --- .../org/apache/celeborn/service/deploy/worker/storage/Flusher.scala | 1 - 1 file changed, 1 deletion(-) diff --git a/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/Flusher.scala b/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/Flusher.scala index 8a662154..1823733c 100644 --- a/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/Flusher.scala +++ b/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/Flusher.scala @@ -189,7 +189,6 @@ private[worker] class LocalFlusher( deviceMonitor.registerFlusher(this) override def processIOException(e: IOException, deviceErrorType: DiskStatus): Unit = { - stopFlag.set(true) logError(s"$this write failed, report to DeviceMonitor, exception: $e") deviceMonitor.reportNonCriticalError(mountPoint, e, deviceErrorType) }
