diff options
| author | Aaron Davidson <aaron@databricks.com> | 2014-07-17 01:01:14 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2014-07-17 01:01:14 -0700 |
| commit | 7c23c0dc3ed721c95690fc49f435d9de6952523c (patch) | |
| tree | 24916b22933995a60f0f14b4ebf58ca28fa0ad2f /NOTICE | |
| parent | 9c249743eaabe5fc8d961c7aa581cc0197f6e950 (diff) | |
| download | spark-7c23c0dc3ed721c95690fc49f435d9de6952523c.tar.gz spark-7c23c0dc3ed721c95690fc49f435d9de6952523c.tar.bz2 spark-7c23c0dc3ed721c95690fc49f435d9de6952523c.zip | |
[SPARK-2412] CoalescedRDD throws exception with certain pref locs
If the first pass of CoalescedRDD does not find the target number of locations AND the second pass finds new locations, an exception is thrown, as "groupHash.get(nxt_replica).get" is not valid.
The fix is just to add an ArrayBuffer to groupHash for that replica if it didn't already exist.
Author: Aaron Davidson <aaron@databricks.com>
Closes #1337 from aarondav/2412 and squashes the following commits:
f587b5d [Aaron Davidson] getOrElseUpdate
3ad8a3c [Aaron Davidson] [SPARK-2412] CoalescedRDD throws exception with certain pref locs
Diffstat (limited to 'NOTICE')
0 files changed, 0 insertions, 0 deletions