File tree Expand file tree Collapse file tree 1 file changed +1
-2
lines changed
mllib/src/main/scala/org/apache/spark/ml/optim/aggregator Expand file tree Collapse file tree 1 file changed +1
-2
lines changed Original file line number Diff line number Diff line change @@ -82,7 +82,6 @@ private[ml] class HuberAggregator(
8282 0.0
8383 }
8484 // make transient so we do not serialize between aggregation stages
85- @ transient private lazy val featuresStd = bcFeaturesStd.value
8685 @ transient private lazy val coefficients = bcParameters.value.toArray.slice(0 , numFeatures)
8786
8887 /**
@@ -99,7 +98,7 @@ private[ml] class HuberAggregator(
9998 require(weight >= 0.0 , s " instance weight, $weight has to be >= 0.0 " )
10099
101100 if (weight == 0.0 ) return this
102- val localFeaturesStd = featuresStd
101+ val localFeaturesStd = bcFeaturesStd.value
103102 val localCoefficients = coefficients
104103 val localGradientSumArray = gradientSumArray
105104
You can’t perform that action at this time.
0 commit comments