diff --git a/python/pyspark/mllib/tests.py b/python/pyspark/mllib/tests.py index 79ce4959c9266f6453cf19aa25b2b3cb7fb58b6d..25a7c29982b3baa6faadeaa441f106476696b4f3 100644 --- a/python/pyspark/mllib/tests.py +++ b/python/pyspark/mllib/tests.py @@ -1189,6 +1189,7 @@ class StreamingKMeansTest(MLLibStreamingTestCase): self._eventually(condition, catch_assertions=True) + @unittest.skip("SPARK-10086: Flaky StreamingKMeans test in PySpark") def test_trainOn_predictOn(self): """Test that prediction happens on the updated model.""" stkm = StreamingKMeans(decayFactor=0.0, k=2)