diff options
author | WangTao <barneystinson@aliyun.com> | 2014-04-25 11:47:01 -0700 |
---|---|---|
committer | Reynold Xin <rxin@apache.org> | 2014-04-25 11:47:01 -0700 |
commit | 25a276dd21457fa0db76b6be93765682a50b784a (patch) | |
tree | ba36b41fc8d0579ebfc8deec98f510979bfdb039 /core | |
parent | a24d918c71f6ac4adbe3ae363ef69f4658118938 (diff) | |
download | spark-25a276dd21457fa0db76b6be93765682a50b784a.tar.gz spark-25a276dd21457fa0db76b6be93765682a50b784a.tar.bz2 spark-25a276dd21457fa0db76b6be93765682a50b784a.zip |
Delete the val that never used
It seems that the val "startTime" and "endTime" is never used, so delete them.
Author: WangTao <barneystinson@aliyun.com>
Closes #553 from WangTaoTheTonic/master and squashes the following commits:
4fcb639 [WangTao] Delete the val that never used
Diffstat (limited to 'core')
-rw-r--r-- | core/src/main/scala/org/apache/spark/storage/BlockMessage.scala | 4 |
1 files changed, 0 insertions, 4 deletions
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 337b45b727..a2bfce7b4a 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) } |