diff options
author | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-06-23 10:07:16 -0700 |
---|---|---|
committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-06-23 10:26:53 -0700 |
commit | 78ffe164b33c6b11a2e511442605acd2f795a1b5 (patch) | |
tree | e10925c8e1d675c0a4ee95bd30414dd86ad13922 /streaming | |
parent | 0e0f9d3069039f03bbf5eefe3b0637c89fddf0f1 (diff) | |
download | spark-78ffe164b33c6b11a2e511442605acd2f795a1b5.tar.gz spark-78ffe164b33c6b11a2e511442605acd2f795a1b5.tar.bz2 spark-78ffe164b33c6b11a2e511442605acd2f795a1b5.zip |
Clone the zero value for each key in foldByKey
The old version reused the object within each task, leading to
overwriting of the object when a mutable type is used, which is expected
to be common in fold.
Conflicts:
core/src/test/scala/spark/ShuffleSuite.scala
Diffstat (limited to 'streaming')
0 files changed, 0 insertions, 0 deletions