Skip to content

Commit 2077457

Browse files
committed
solve mima failure
1 parent a6b5a16 commit 2077457

File tree

2 files changed

+4
-7
lines changed

2 files changed

+4
-7
lines changed

mllib/src/main/scala/org/apache/spark/ml/recommendation/ALS.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -485,8 +485,8 @@ class ALS(@Since("1.4.0") override val uid: String) extends Estimator[ALSModel]
485485
alpha = $(alpha), nonnegative = $(nonnegative),
486486
intermediateRDDStorageLevel = StorageLevel.fromString($(intermediateStorageLevel)),
487487
finalRDDStorageLevel = StorageLevel.fromString($(finalStorageLevel)),
488-
threshold = $(threshold), checkpointInterval = $(checkpointInterval),
489-
seed = $(seed))
488+
checkpointInterval = $(checkpointInterval),
489+
seed = $(seed), threshold = $(threshold))
490490
val userDF = userFactors.toDF("id", "features")
491491
val itemDF = itemFactors.toDF("id", "features")
492492
val model = new ALSModel(uid, $(rank), userDF, itemDF).setParent(this)
@@ -721,9 +721,9 @@ object ALS extends DefaultParamsReadable[ALS] with Logging {
721721
nonnegative: Boolean = false,
722722
intermediateRDDStorageLevel: StorageLevel = StorageLevel.MEMORY_AND_DISK,
723723
finalRDDStorageLevel: StorageLevel = StorageLevel.MEMORY_AND_DISK,
724-
threshold: Int = 1024,
725724
checkpointInterval: Int = 10,
726-
seed: Long = 0L)(
725+
seed: Long = 0L,
726+
threshold: Int = 1024)(
727727
implicit ord: Ordering[ID]): (RDD[(ID, Array[Float])], RDD[(ID, Array[Float])]) = {
728728
require(intermediateRDDStorageLevel != StorageLevel.NONE,
729729
"ALS is not designed to run without persisting intermediate RDDs.")

project/MimaExcludes.scala

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -864,9 +864,6 @@ object MimaExcludes {
864864
// [SPARK-12221] Add CPU time to metrics
865865
ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.spark.status.api.v1.TaskMetrics.this"),
866866
ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.spark.status.api.v1.TaskMetricDistributions.this")
867-
) ++ Seq(
868-
// SPARK-6685
869-
ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.spark.ml.recommendation.ALS.train")
870867
)
871868
}
872869

0 commit comments

Comments
 (0)