GitHub user Qiuzhuang opened a pull request:
https://github.com/apache/incubator-spark/pull/561
Kill drivers in postStop() for Worker.
JIRA SPARK-1068:https://spark-project.atlassian.net/browse/SPARK-1068
You can merge this pull request into a Git repository by running:
$ git
Github user Qiuzhuang closed the pull request at:
https://github.com/apache/incubator-spark/pull/561
GitHub user Qiuzhuang opened a pull request:
https://github.com/apache/incubator-spark/pull/594
Set ContextWaiter's var stopped to be true if wait() has been triggered
[STREAMING-58]: https://spark-project.atlassian.net/browse/STREAMING-58
You can merge this pull request into
I see this error thrown from Executor.scala:
task = ser.deserialize[Task[Any]](taskBytes,
Thread.currentThread.getContextClassLoader)
Any suggestions to break down the task to smaller chunk to avoid this?
Thanks,
Qiuzhuang
On Sun, Jan 26, 2014 at 2:52 PM, Shao, Saisai wrote:
> In my t
