This is an automated email from the ASF dual-hosted git repository. dongjoon pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push: new 370870b7a03 [SPARK-45803][CORE] Remove the no longer used `RpcAbortException` 370870b7a03 is described below commit 370870b7a0303e4a2c4b3dea1b479b4fcbc93f8d Author: yangjie01 <yangji...@baidu.com> AuthorDate: Mon Nov 6 12:48:52 2023 -0800 [SPARK-45803][CORE] Remove the no longer used `RpcAbortException` ### What changes were proposed in this pull request? `RpcAbortException` introduced in SPARK-28483 | https://github.com/apache/spark/pull/25235 and become unused after SPARK-31472 | https://github.com/apache/spark/pull/28245. At the same time, `RpcAbortException` is a `private[spark]` definition, so this pr removes it. ### Why are the changes needed? Clean up useless code. ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? Pass GitHub Actions ### Was this patch authored or co-authored using generative AI tooling? No Closes #43673 from LuciferYang/SPARK-45803. Authored-by: yangjie01 <yangji...@baidu.com> Signed-off-by: Dongjoon Hyun <dh...@apple.com> --- .../src/main/scala/org/apache/spark/util/SparkThreadUtils.scala | 2 +- core/src/main/scala/org/apache/spark/rpc/RpcEndpointRef.scala | 5 ----- 2 files changed, 1 insertion(+), 6 deletions(-) diff --git a/common/utils/src/main/scala/org/apache/spark/util/SparkThreadUtils.scala b/common/utils/src/main/scala/org/apache/spark/util/SparkThreadUtils.scala index ec14688a006..a5e4cef1ec1 100644 --- a/common/utils/src/main/scala/org/apache/spark/util/SparkThreadUtils.scala +++ b/common/utils/src/main/scala/org/apache/spark/util/SparkThreadUtils.scala @@ -49,7 +49,7 @@ private[spark] object SparkThreadUtils { } catch { case e: SparkFatalException => throw e.throwable - // TimeoutException and RpcAbortException is thrown in the current thread, so not need to warp + // TimeoutException is thrown in the current thread, so not need to warp // the exception. case NonFatal(t) if !t.isInstanceOf[TimeoutException] => diff --git a/core/src/main/scala/org/apache/spark/rpc/RpcEndpointRef.scala b/core/src/main/scala/org/apache/spark/rpc/RpcEndpointRef.scala index 925dcdba073..d907763639f 100644 --- a/core/src/main/scala/org/apache/spark/rpc/RpcEndpointRef.scala +++ b/core/src/main/scala/org/apache/spark/rpc/RpcEndpointRef.scala @@ -103,11 +103,6 @@ private[spark] abstract class RpcEndpointRef(conf: SparkConf) } -/** - * An exception thrown if the RPC is aborted. - */ -private[spark] class RpcAbortException(message: String) extends Exception(message) - /** * A wrapper for [[Future]] but add abort method. * This is used in long run RPC and provide an approach to abort the RPC. --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org