Skip to content

Commit 06afa53

Browse files
committed
[SPARK-6980] RpcTimeout class extends Serializable, was causing error in MasterSuite
1 parent 7bb70f1 commit 06afa53

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -201,7 +201,8 @@ private[rpc] class RpcTimeoutException(message: String, cause: TimeoutException)
201201
* @param duration timeout duration in seconds
202202
* @param timeoutProp the configuration property that controls this timeout
203203
*/
204-
private[spark] class RpcTimeout(val duration: FiniteDuration, val timeoutProp: String) {
204+
private[spark] class RpcTimeout(val duration: FiniteDuration, val timeoutProp: String)
205+
extends Serializable {
205206

206207
/** Amends the standard message of TimeoutException to include the description */
207208
private def createRpcTimeoutException(te: TimeoutException): RpcTimeoutException = {

0 commit comments

Comments
 (0)