Repository: spark Updated Branches: refs/heads/branch-1.0 2c8dfd417 -> 97bfeda9f
Delete the val that never used It seems that the val "startTime" and "endTime" is never used, so delete them. Author: WangTao <[email protected]> Closes #553 from WangTaoTheTonic/master and squashes the following commits: 4fcb639 [WangTao] Delete the val that never used (cherry picked from commit 25a276dd21457fa0db76b6be93765682a50b784a) Signed-off-by: Reynold Xin <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/97bfeda9 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/97bfeda9 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/97bfeda9 Branch: refs/heads/branch-1.0 Commit: 97bfeda9f8600e8a351d28efde6d4b735d14e4b7 Parents: 2c8dfd4 Author: WangTao <[email protected]> Authored: Fri Apr 25 11:47:01 2014 -0700 Committer: Reynold Xin <[email protected]> Committed: Fri Apr 25 11:47:46 2014 -0700 ---------------------------------------------------------------------- core/src/main/scala/org/apache/spark/storage/BlockMessage.scala | 4 ---- 1 file changed, 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/97bfeda9/core/src/main/scala/org/apache/spark/storage/BlockMessage.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/org/apache/spark/storage/BlockMessage.scala b/core/src/main/scala/org/apache/spark/storage/BlockMessage.scala index 337b45b..a2bfce7 100644 --- a/core/src/main/scala/org/apache/spark/storage/BlockMessage.scala +++ b/core/src/main/scala/org/apache/spark/storage/BlockMessage.scala @@ -57,7 +57,6 @@ private[spark] class BlockMessage() { } def set(buffer: ByteBuffer) { - val startTime = System.currentTimeMillis /* println() println("BlockMessage: ") @@ -100,7 +99,6 @@ private[spark] class BlockMessage() { data.flip() } - val finishTime = System.currentTimeMillis } def set(bufferMsg: BufferMessage) { @@ -115,7 +113,6 @@ private[spark] class BlockMessage() { def getLevel: StorageLevel = level def toBufferMessage: BufferMessage = { - val startTime = System.currentTimeMillis val buffers = new ArrayBuffer[ByteBuffer]() var buffer = ByteBuffer.allocate(4 + 4 + id.name.length * 2) buffer.putInt(typ).putInt(id.name.length) @@ -153,7 +150,6 @@ private[spark] class BlockMessage() { println() println() */ - val finishTime = System.currentTimeMillis Message.createBufferMessage(buffers) }
