File tree Expand file tree Collapse file tree 2 files changed +1
-5
lines changed
core/src/main/scala/org/apache/spark Expand file tree Collapse file tree 2 files changed +1
-5
lines changed Original file line number Diff line number Diff line change @@ -279,7 +279,7 @@ object AccumulatorParam {
279
279
280
280
// TODO: The multi-thread support in accumulators is kind of lame; check
281
281
// if there's a more intuitive way of doing it right
282
- private object Accumulators {
282
+ private [spark] object Accumulators {
283
283
// TODO: Use soft references? => need to make readObject work properly then
284
284
val originals = Map [Long , Accumulable [_, _]]()
285
285
val localAccums = new ThreadLocal [Map [Long , Accumulable [_, _]]]() {
Original file line number Diff line number Diff line change @@ -53,10 +53,6 @@ object MimaExcludes {
53
53
" org.apache.spark.mllib.linalg.Matrices.randn" ),
54
54
ProblemFilters .exclude[MissingMethodProblem ](
55
55
" org.apache.spark.mllib.linalg.Matrices.rand" )
56
- ) ++ Seq (
57
- // SPARK-4772
58
- ProblemFilters .exclude[IncompatibleResultTypeProblem ](
59
- " org.apache.spark.Accumulators.localAccums" )
60
56
)
61
57
62
58
case v if v.startsWith(" 1.2" ) =>
You can’t perform that action at this time.
0 commit comments