diff options
| author | Marcelo Vanzin <vanzin@cloudera.com> | 2014-04-21 23:10:53 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2014-04-21 23:11:10 -0700 |
| commit | 0a731039e6fd0124dd743d3de549cd3fd0d53fbc (patch) | |
| tree | f29395217066a7c136ed2d0b7fa3375707db4d1e /core | |
| parent | b0d70e40f0d0ecc002cda295a0c83b5a16c3c4a4 (diff) | |
| download | spark-0a731039e6fd0124dd743d3de549cd3fd0d53fbc.tar.gz spark-0a731039e6fd0124dd743d3de549cd3fd0d53fbc.tar.bz2 spark-0a731039e6fd0124dd743d3de549cd3fd0d53fbc.zip | |
[SPARK-1459] Use local path (and not complete URL) when opening local lo...
...g file.
Author: Marcelo Vanzin <vanzin@cloudera.com>
Closes #375 from vanzin/event-file and squashes the following commits:
f673029 [Marcelo Vanzin] [SPARK-1459] Use local path (and not complete URL) when opening local log file.
(cherry picked from commit ac164b79d12f5a269d9c05d04dced51a415e3b0e)
Signed-off-by: Patrick Wendell <pwendell@gmail.com>
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/util/FileLogger.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/util/FileLogger.scala b/core/src/main/scala/org/apache/spark/util/FileLogger.scala index 68a12e8ed6..7d58d1c765 100644 --- a/core/src/main/scala/org/apache/spark/util/FileLogger.scala +++ b/core/src/main/scala/org/apache/spark/util/FileLogger.scala @@ -91,7 +91,7 @@ private[spark] class FileLogger( val dstream = uri.getScheme match { case "file" | null => // Second parameter is whether to append - new FileOutputStream(logPath, !overwrite) + new FileOutputStream(uri.getPath, !overwrite) case _ => val path = new Path(logPath) |