This is an automated email from the ASF dual-hosted git repository. xianjingfeng pushed a commit to branch branch-0.8 in repository https://gitbox.apache.org/repos/asf/incubator-uniffle.git
commit f6eae7e94bc4b56fd71dfa86602fd7cbea5aa0bb Author: Zhen Wang <[email protected]> AuthorDate: Tue Oct 24 13:37:07 2023 +0800 [#1261] fix(spark): Throw out InterruptedException for sleep in requestExecutorMemory #1262 ### What changes were proposed in this pull request? Pass InterruptedException in requestExecutorMemory. ### Why are the changes needed? Fix: #1261 ### Does this PR introduce _any_ user-facing change? No. ### How was this patch tested? Existing tests. (cherry picked from commit 9dd4c4df3617e72288ae77b58ac8907229e9e9ef) --- .../main/java/org/apache/spark/shuffle/writer/WriteBufferManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/client-spark/common/src/main/java/org/apache/spark/shuffle/writer/WriteBufferManager.java b/client-spark/common/src/main/java/org/apache/spark/shuffle/writer/WriteBufferManager.java index 27fb40a21..027be97af 100644 --- a/client-spark/common/src/main/java/org/apache/spark/shuffle/writer/WriteBufferManager.java +++ b/client-spark/common/src/main/java/org/apache/spark/shuffle/writer/WriteBufferManager.java @@ -365,7 +365,7 @@ public class WriteBufferManager extends MemoryConsumer { try { Thread.sleep(requireMemoryInterval); } catch (InterruptedException ie) { - LOG.warn("Exception happened when waiting for memory.", ie); + throw new RssException("Interrupted when waiting for memory.", ie); } gotMem = acquireMemory(askExecutorMemory); allocatedBytes.addAndGet(gotMem);
