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 <[email protected]>
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 <[email protected]>
Signed-off-by: Dongjoon Hyun <[email protected]>
---
.../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: [email protected]
For additional commands, e-mail: [email protected]
