diff options
| author | Aaron Davidson <aaron@databricks.com> | 2013-10-13 11:15:02 -0700 |
|---|---|---|
| committer | Aaron Davidson <aaron@databricks.com> | 2013-10-13 11:15:02 -0700 |
| commit | da896115ec8861f78922fa9502ef257b1e54e3c2 (patch) | |
| tree | f1b48c15709b5e6f322f699f9f04981fb3caaf5b /core/src/main/java | |
| parent | d60352283cdc34722749024f6fd47e9309f01e37 (diff) | |
| download | spark-da896115ec8861f78922fa9502ef257b1e54e3c2.tar.gz spark-da896115ec8861f78922fa9502ef257b1e54e3c2.tar.bz2 spark-da896115ec8861f78922fa9502ef257b1e54e3c2.zip | |
Change BlockId filename to name + rest of Patrick'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 299162f12c..097b2ad6d5 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.filename()); + String path = pResolver.getAbsolutePath(blockId.asFilename()); // if getFilePath returns null, close the channel if (path == null) { //ctx.close(); |