aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/sql/streaming.py
diff options
context:
space:
mode:
authorSun Rui <sunrui2016@gmail.com>2016-07-01 14:37:03 -0700
committerShivaram Venkataraman <shivaram@cs.berkeley.edu>2016-07-01 14:37:03 -0700
commite4fa58c43ce2bf8d76bffb0d9dc1132f8d0eae6a (patch)
tree0c5a1d41b89a3a78fbbb6cc2776e52d7acb6ea6f /python/pyspark/sql/streaming.py
parent26afb4ce4099e7942f8db1ead3817ed8fbf71ce3 (diff)
downloadspark-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 'python/pyspark/sql/streaming.py')
0 files changed, 0 insertions, 0 deletions