diff --git a/python/pyspark/mllib/tests/test_streaming_algorithms.py b/python/pyspark/mllib/tests/test_streaming_algorithms.py index f6c6779e83..ba0c86f646 100644 --- a/python/pyspark/mllib/tests/test_streaming_algorithms.py +++ b/python/pyspark/mllib/tests/test_streaming_algorithms.py @@ -388,7 +388,7 @@ class StreamingLinearRegressionWithTests(MLLibStreamingTestCase): return True # We want all batches to finish for this test. - eventually(condition, catch_assertions=True) + eventually(condition, 90, catch_assertions=True) w = array(model_weights) diff = w[1:] - w[:-1]