Skip to content

Commit df3f21e

Browse files
committed
[SPARK-32506] Flaky test: StreamingLinearRegressionWithTests
1 parent 1b6f482 commit df3f21e

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

python/pyspark/mllib/tests/test_streaming_algorithms.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -434,9 +434,9 @@ def test_train_prediction(self):
434434
slr = StreamingLinearRegressionWithSGD(stepSize=0.2, numIterations=25)
435435
slr.setInitialWeights([0.0])
436436

437-
# Create ten batches with 100 sample points in each.
437+
# Create fifteen batches with 100 sample points in each.
438438
batches = []
439-
for i in range(10):
439+
for i in range(15):
440440
batch = LinearDataGenerator.generateLinearInput(
441441
0.0, [10.0], [0.0], [1.0 / 3.0], 100, 42 + i, 0.1)
442442
batches.append(self.sc.parallelize(batch))

0 commit comments

Comments
 (0)