You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2014/04/22 08:11:05 UTC
git commit: [SPARK-1459] Use local path (and not complete URL) when
opening local lo...
Repository: spark
Updated Branches:
refs/heads/master b3e5366f6 -> ac164b79d
[SPARK-1459] Use local path (and not complete URL) when opening local lo...
...g file.
Author: Marcelo Vanzin <va...@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.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/ac164b79
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/ac164b79
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/ac164b79
Branch: refs/heads/master
Commit: ac164b79d12f5a269d9c05d04dced51a415e3b0e
Parents: b3e5366
Author: Marcelo Vanzin <va...@cloudera.com>
Authored: Mon Apr 21 23:10:53 2014 -0700
Committer: Patrick Wendell <pw...@gmail.com>
Committed: Mon Apr 21 23:10:53 2014 -0700
----------------------------------------------------------------------
core/src/main/scala/org/apache/spark/util/FileLogger.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/ac164b79/core/src/main/scala/org/apache/spark/util/FileLogger.scala
----------------------------------------------------------------------
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 68a12e8..7d58d1c 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)