We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4141f58 commit c6693a8Copy full SHA for c6693a8
core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosTaskLaunchData.scala
@@ -34,8 +34,8 @@ private[spark] case class MesosTaskLaunchData(
34
val dataBuffer = ByteBuffer.allocate(4 + serializedTask.limit)
35
dataBuffer.putInt(attemptNumber)
36
dataBuffer.put(serializedTask)
37
- logDebug(s"ByteBuffer size: [${dataBuffer.remaining}]")
38
dataBuffer.rewind
+ logDebug(s"ByteBuffer size: [${dataBuffer.remaining}]")
39
ByteString.copyFrom(dataBuffer)
40
}
41
0 commit comments