From d60352283cdc34722749024f6fd47e9309f01e37 Mon Sep 17 00:00:00 2001 From: Aaron Davidson Date: Sat, 12 Oct 2013 22:28:31 -0700 Subject: Add unit test and address rest of Reynold's comments --- .../src/main/java/org/apache/spark/network/netty/FileServerHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'core/src/main/java') diff --git a/core/src/main/java/org/apache/spark/network/netty/FileServerHandler.java b/core/src/main/java/org/apache/spark/network/netty/FileServerHandler.java index a5ec5e2fb1..299162f12c 100644 --- a/core/src/main/java/org/apache/spark/network/netty/FileServerHandler.java +++ b/core/src/main/java/org/apache/spark/network/netty/FileServerHandler.java @@ -36,7 +36,7 @@ class FileServerHandler extends ChannelInboundMessageHandlerAdapter { @Override public void messageReceived(ChannelHandlerContext ctx, String blockIdString) { - BlockId blockId = BlockId.fromString(blockIdString); + BlockId blockId = BlockId.apply(blockIdString); String path = pResolver.getAbsolutePath(blockId.filename()); // if getFilePath returns null, close the channel if (path == null) { -- cgit v1.2.3