Skip to content

Commit cfdd286

Browse files
author
Andrew MacKinlay
committed
[SPARK-19234][MLLib] added test case to ensure fast failure on zero labels in AFT
1 parent 0efbf0f commit cfdd286

1 file changed

Lines changed: 11 additions & 2 deletions

File tree

mllib/src/test/scala/org/apache/spark/ml/regression/AFTSurvivalRegressionSuite.scala

Lines changed: 11 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,8 +32,6 @@ class AFTSurvivalRegressionSuite
3232
extends SparkFunSuite with MLlibTestSparkContext with DefaultReadWriteTest {
3333

3434
import testImplicits._
35-
import AFTSurvivalRegressionSuite._
36-
3735

3836
@transient var datasetUnivariate: DataFrame = _
3937
@transient var datasetMultivariate: DataFrame = _
@@ -402,6 +400,17 @@ class AFTSurvivalRegressionSuite
402400
val trainer = new AFTSurvivalRegression()
403401
trainer.fit(dataset)
404402
}
403+
404+
test("SPARK-19234: Fail fast on zero-valued labels") {
405+
val dataset = spark.createDataFrame(Seq(
406+
(1.218, 1.0, Vectors.dense(1.560, -0.605)),
407+
(0.000, 0.0, Vectors.dense(0.346, 2.158)), // ← generates error; zero labels invalid
408+
(4.199, 0.0, Vectors.dense(0.795, -0.226)))).toDF("label", "censor", "features")
409+
val aft = new AFTSurvivalRegression()
410+
intercept[SparkException] {
411+
aft.fit(dataset)
412+
}
413+
}
405414
}
406415

407416
object AFTSurvivalRegressionSuite {

0 commit comments

Comments
 (0)