Heartbeat and HeartbeatResponse are already Serializable as case classes

xiliu82 · Aug 1, 2014 · 132aec7 · 132aec7
1 parent 38dffde
commit 132aec7
Showing 1 changed file with 1 addition and 2 deletions.
diff --git 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..