diff options
| author | Aaron Davidson <aaron@databricks.com> | 2013-10-12 22:28:31 -0700 |
|---|---|---|
| committer | Aaron Davidson <aaron@databricks.com> | 2013-10-12 22:45:15 -0700 |
| commit | d60352283cdc34722749024f6fd47e9309f01e37 (patch) | |
| tree | 51350e1711cff837c9617f6273d92d573d75efcc /core/src/main/java | |
| parent | a3959111387ae955c63284b389cc888cbd19e399 (diff) | |
| download | spark-d60352283cdc34722749024f6fd47e9309f01e37.tar.gz spark-d60352283cdc34722749024f6fd47e9309f01e37.tar.bz2 spark-d60352283cdc34722749024f6fd47e9309f01e37.zip | |
Add unit test and address rest of Reynold's comments
Diffstat (limited to 'core/src/main/java')
| -rw-r--r-- | core/src/main/java/org/apache/spark/network/netty/FileServerHandler.java | 2 |
1 files changed, 1 insertions, 1 deletions
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<String> { @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) { |