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:10:53 -0700 |
| commit | ac164b79d12f5a269d9c05d04dced51a415e3b0e (patch) | |
| tree | 10169ecf6257f65ecf965a07d672d8e0cfe9a70c /core | |
| parent | b3e5366f696c463f1c2f033b0d5c7365e5d6b0f8 (diff) | |
| download | spark-ac164b79d12f5a269d9c05d04dced51a415e3b0e.tar.gz spark-ac164b79d12f5a269d9c05d04dced51a415e3b0e.tar.bz2 spark-ac164b79d12f5a269d9c05d04dced51a415e3b0e.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.
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) |