aboutsummaryrefslogtreecommitdiff
path: root/python
diff options
context:
space:
mode:
authorMatei Zaharia <matei@databricks.com>2014-08-04 12:59:18 -0700
committerMatei Zaharia <matei@databricks.com>2014-08-04 14:28:22 -0700
commitaa7a48ee905b95e57f64051ea887d4775b427603 (patch)
tree22128614dde4f880b0036bb7fa816d91318ee183 /python
parentbfd2f39581d958d5aafaa76994f44213bcdfbb69 (diff)
downloadspark-aa7a48ee905b95e57f64051ea887d4775b427603.tar.gz
spark-aa7a48ee905b95e57f64051ea887d4775b427603.tar.bz2
spark-aa7a48ee905b95e57f64051ea887d4775b427603.zip
SPARK-2792. Fix reading too much or too little data from each stream in ExternalMap / Sorter
All these changes are from mridulm's work in #1609, but extracted here to fix this specific issue and make it easier to merge not 1.1. This particular set of changes is to make sure that we read exactly the right range of bytes from each spill file in EAOM: some serializers can write bytes after the last object (e.g. the TC_RESET flag in Java serialization) and that would confuse the previous code into reading it as part of the next batch. There are also improvements to cleanup to make sure files are closed. In addition to bringing in the changes to ExternalAppendOnlyMap, I also copied them to the corresponding code in ExternalSorter and updated its test suite to test for the same issues. Author: Matei Zaharia <matei@databricks.com> Closes #1722 from mateiz/spark-2792 and squashes the following commits: 5d4bfb5 [Matei Zaharia] Make objectStreamReset counter count the last object written too 18fe865 [Matei Zaharia] Update docs on objectStreamReset 576ee83 [Matei Zaharia] Allow objectStreamReset to be 0 0374217 [Matei Zaharia] Remove super paranoid code to close file handles bda37bb [Matei Zaharia] Implement Mridul's ExternalAppendOnlyMap fixes in ExternalSorter too 0d6dad7 [Matei Zaharia] Added Mridul's test changes for ExternalAppendOnlyMap 9a78e4b [Matei Zaharia] Add @mridulm's fixes to ExternalAppendOnlyMap for batch sizes
Diffstat (limited to 'python')
0 files changed, 0 insertions, 0 deletions