Skip to content

Commit 0dae310

Browse files
committed
Merge with latest master.
1 parent 0140d6e commit 0dae310

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

core/src/main/scala/org/apache/spark/network/nio/NioBlockTransferService.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -201,10 +201,9 @@ final class NioBlockTransferService(conf: SparkConf, securityManager: SecurityMa
201201
private def getBlock(blockId: String): ByteBuffer = {
202202
val startTimeMs = System.currentTimeMillis()
203203
logDebug("GetBlock " + blockId + " started from " + startTimeMs)
204-
// TODO(rxin): propagate error back to the client?
205204
val buffer = blockDataManager.getBlockData(blockId)
206205
logDebug("GetBlock " + blockId + " used " + Utils.getUsedTimeMs(startTimeMs)
207206
+ " and got buffer " + buffer)
208-
if (buffer == null) null else buffer.nioByteBuffer()
207+
buffer.nioByteBuffer()
209208
}
210209
}

0 commit comments

Comments
 (0)