From 132aec7f3fb79b74ebb2b21e7640b1d66f3179da Mon Sep 17 00:00:00 2001 From: Sandy Ryza Date: Thu, 31 Jul 2014 20:12:07 -0700 Subject: [PATCH] Heartbeat and HeartbeatResponse are already Serializable as case classes --- core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala b/core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala index 175e59082b85e..24ccce21b62ca 100644 --- a/core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala +++ b/core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala @@ -30,9 +30,8 @@ private[spark] case class Heartbeat( executorId: String, taskMetrics: Array[(Long, TaskMetrics)], // taskId -> TaskMetrics blockManagerId: BlockManagerId) - extends Serializable -private[spark] case class HeartbeatResponse(reregisterBlockManager: Boolean) extends Serializable +private[spark] case class HeartbeatResponse(reregisterBlockManager: Boolean) /** * Lives in the driver to receive heartbeats from executors..