(spark) branch master updated: [SPARK-45803][CORE] Remove the no longer used `RpcAbortException`

[dongjoon]

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