diff options
| author | Sun Rui <sunrui2016@gmail.com> | 2016-07-01 14:37:03 -0700 |
|---|---|---|
| committer | Shivaram Venkataraman <shivaram@cs.berkeley.edu> | 2016-07-01 14:37:03 -0700 |
| commit | e4fa58c43ce2bf8d76bffb0d9dc1132f8d0eae6a (patch) | |
| tree | 0c5a1d41b89a3a78fbbb6cc2776e52d7acb6ea6f /R/pkg | |
| parent | 26afb4ce4099e7942f8db1ead3817ed8fbf71ce3 (diff) | |
| download | spark-e4fa58c43ce2bf8d76bffb0d9dc1132f8d0eae6a.tar.gz spark-e4fa58c43ce2bf8d76bffb0d9dc1132f8d0eae6a.tar.bz2 spark-e4fa58c43ce2bf8d76bffb0d9dc1132f8d0eae6a.zip | |
[SPARK-16299][SPARKR] Capture errors from R workers in daemon.R to avoid deletion of R session temporary directory.
## What changes were proposed in this pull request?
Capture errors from R workers in daemon.R to avoid deletion of R session temporary directory. See detailed description at https://issues.apache.org/jira/browse/SPARK-16299
## How was this patch tested?
SparkR unit tests.
Author: Sun Rui <sunrui2016@gmail.com>
Closes #13975 from sun-rui/SPARK-16299.
Diffstat (limited to 'R/pkg')
| -rw-r--r-- | R/pkg/inst/worker/daemon.R | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/R/pkg/inst/worker/daemon.R b/R/pkg/inst/worker/daemon.R index f55beac6c8..b92e6be995 100644 --- a/R/pkg/inst/worker/daemon.R +++ b/R/pkg/inst/worker/daemon.R @@ -44,7 +44,7 @@ while (TRUE) { if (inherits(p, "masterProcess")) { close(inputCon) Sys.setenv(SPARKR_WORKER_PORT = port) - source(script) + try(source(script)) # Set SIGUSR1 so that child can exit tools::pskill(Sys.getpid(), tools::SIGUSR1) parallel:::mcexit(0L) |