diff options
| author | zsxwing <zsxwing@gmail.com> | 2014-09-25 18:24:01 -0700 |
|---|---|---|
| committer | Josh Rosen <joshrosen@apache.org> | 2014-09-25 18:24:01 -0700 |
| commit | 86bce764983f2b14e1bd87fc3f4f938f7a217e1b (patch) | |
| tree | 371aa5632998663eee624f449ce0fe08edbf7f35 /external/flume-sink | |
| parent | 0dc868e787a3bc69c1b8e90d916a6dcea8dbcd6d (diff) | |
| download | spark-86bce764983f2b14e1bd87fc3f4f938f7a217e1b.tar.gz spark-86bce764983f2b14e1bd87fc3f4f938f7a217e1b.tar.bz2 spark-86bce764983f2b14e1bd87fc3f4f938f7a217e1b.zip | |
SPARK-2634: Change MapOutputTrackerWorker.mapStatuses to ConcurrentHashMap
MapOutputTrackerWorker.mapStatuses is used concurrently, it should be thread-safe. This bug has already been fixed in #1328. Nevertheless, considering #1328 won't be merged soon, I send this trivial fix and hope this issue can be solved soon.
Author: zsxwing <zsxwing@gmail.com>
Closes #1541 from zsxwing/SPARK-2634 and squashes the following commits:
d450053 [zsxwing] SPARK-2634: Change MapOutputTrackerWorker.mapStatuses to ConcurrentHashMap
Diffstat (limited to 'external/flume-sink')
0 files changed, 0 insertions, 0 deletions