diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-05-11 23:53:50 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-05-11 23:53:50 -0700 |
| commit | 72b9c4cb6ec4080eb8751e5e040f180272ac82a6 (patch) | |
| tree | e8691c3444b55129510bd4c28df020558c14957d /core | |
| parent | 1c15b8505124c157449b6d41e1127f3eb4081a23 (diff) | |
| download | spark-72b9c4cb6ec4080eb8751e5e040f180272ac82a6.tar.gz spark-72b9c4cb6ec4080eb8751e5e040f180272ac82a6.tar.bz2 spark-72b9c4cb6ec4080eb8751e5e040f180272ac82a6.zip | |
Small fix
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/scheduler/local/LocalScheduler.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/scheduler/local/LocalScheduler.scala b/core/src/main/scala/spark/scheduler/local/LocalScheduler.scala index 42d5bc4813..a357422466 100644 --- a/core/src/main/scala/spark/scheduler/local/LocalScheduler.scala +++ b/core/src/main/scala/spark/scheduler/local/LocalScheduler.scala @@ -103,7 +103,7 @@ private[spark] class LocalScheduler(threads: Int, maxFailures: Int, sc: SparkCon // TODO: Do something nicer here to return all the way to the user if (!Thread.currentThread().isInterrupted) listener.taskEnded( - task, new ExceptionFailure(t.getMessage, t.getStackTrace), null, null, info, null) + task, new ExceptionFailure(t.toString, t.getStackTrace), null, null, info, null) } } } |