File tree Expand file tree Collapse file tree 1 file changed +0
-4
lines changed
core/src/main/scala/org/apache/spark/storage Expand file tree Collapse file tree 1 file changed +0
-4
lines changed Original file line number Diff line number Diff line change @@ -57,7 +57,6 @@ private[spark] class BlockMessage() {
57
57
}
58
58
59
59
def set (buffer : ByteBuffer ) {
60
- val startTime = System .currentTimeMillis
61
60
/*
62
61
println()
63
62
println("BlockMessage: ")
@@ -100,7 +99,6 @@ private[spark] class BlockMessage() {
100
99
data.flip()
101
100
}
102
101
103
- val finishTime = System .currentTimeMillis
104
102
}
105
103
106
104
def set (bufferMsg : BufferMessage ) {
@@ -115,7 +113,6 @@ private[spark] class BlockMessage() {
115
113
def getLevel : StorageLevel = level
116
114
117
115
def toBufferMessage : BufferMessage = {
118
- val startTime = System .currentTimeMillis
119
116
val buffers = new ArrayBuffer [ByteBuffer ]()
120
117
var buffer = ByteBuffer .allocate(4 + 4 + id.name.length * 2 )
121
118
buffer.putInt(typ).putInt(id.name.length)
@@ -153,7 +150,6 @@ private[spark] class BlockMessage() {
153
150
println()
154
151
println()
155
152
*/
156
- val finishTime = System .currentTimeMillis
157
153
Message .createBufferMessage(buffers)
158
154
}
159
155
You can’t perform that action at this time.
0 commit comments