diff options
| author | Aaron Davidson <aaron@databricks.com> | 2013-10-14 00:24:17 -0700 |
|---|---|---|
| committer | Aaron Davidson <aaron@databricks.com> | 2013-10-14 00:24:17 -0700 |
| commit | 4a45019fb0458b5f943253c0c16c9e257ef2c129 (patch) | |
| tree | abb8d32dafb29492491caa906e8896abfe000c31 /core/src/main/java | |
| parent | da896115ec8861f78922fa9502ef257b1e54e3c2 (diff) | |
| download | spark-4a45019fb0458b5f943253c0c16c9e257ef2c129.tar.gz spark-4a45019fb0458b5f943253c0c16c9e257ef2c129.tar.bz2 spark-4a45019fb0458b5f943253c0c16c9e257ef2c129.zip | |
Address Matei'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 097b2ad6d5..cfd8132891 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 @@ -37,7 +37,7 @@ class FileServerHandler extends ChannelInboundMessageHandlerAdapter<String> { @Override public void messageReceived(ChannelHandlerContext ctx, String blockIdString) { BlockId blockId = BlockId.apply(blockIdString); - String path = pResolver.getAbsolutePath(blockId.asFilename()); + String path = pResolver.getAbsolutePath(blockId.name()); // if getFilePath returns null, close the channel if (path == null) { //ctx.close(); |