diff options
| author | Davies Liu <davies@databricks.com> | 2015-03-09 16:24:06 -0700 |
|---|---|---|
| committer | Josh Rosen <joshrosen@databricks.com> | 2015-03-09 16:24:06 -0700 |
| commit | 8767565cef01d847f57b7293d8b63b2422009b90 (patch) | |
| tree | 1204ac7a7cda19b30e2a990ae2ded5f5b40b8c3f /examples | |
| parent | 3cac1991a1def0adaf42face2c578d3ab8c27025 (diff) | |
| download | spark-8767565cef01d847f57b7293d8b63b2422009b90.tar.gz spark-8767565cef01d847f57b7293d8b63b2422009b90.tar.bz2 spark-8767565cef01d847f57b7293d8b63b2422009b90.zip | |
[SPARK-6194] [SPARK-677] [PySpark] fix memory leak in collect()
Because circular reference between JavaObject and JavaMember, an Java object can not be released until Python GC kick in, then it will cause memory leak in collect(), which may consume lots of memory in JVM.
This PR change the way we sending collected data back into Python from local file to socket, which could avoid any disk IO during collect, also avoid any referrers of Java object in Python.
cc JoshRosen
Author: Davies Liu <davies@databricks.com>
Closes #4923 from davies/fix_collect and squashes the following commits:
d730286 [Davies Liu] address comments
24c92a4 [Davies Liu] fix style
ba54614 [Davies Liu] use socket to transfer data from JVM
9517c8f [Davies Liu] fix memory leak in collect()
Diffstat (limited to 'examples')
0 files changed, 0 insertions, 0 deletions