aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorWangTao <barneystinson@aliyun.com>2014-04-25 11:47:01 -0700
committerReynold Xin <rxin@apache.org>2014-04-25 11:47:01 -0700
commit25a276dd21457fa0db76b6be93765682a50b784a (patch)
treeba36b41fc8d0579ebfc8deec98f510979bfdb039
parenta24d918c71f6ac4adbe3ae363ef69f4658118938 (diff)
downloadspark-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
-rw-r--r--core/src/main/scala/org/apache/spark/storage/BlockMessage.scala4
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)
}