Skip to content

Commit 2217f4f

Browse files
committed
Revert "[SPARK-10959] [PYSPARK] StreamingLogisticRegressionWithSGD does not train with given regParam and convergenceTol parameters"
This reverts commit f95129c.
1 parent ebbff39 commit 2217f4f

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

python/pyspark/mllib/classification.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -632,8 +632,7 @@ def update(rdd):
632632
if not rdd.isEmpty():
633633
self._model = LogisticRegressionWithSGD.train(
634634
rdd, self.numIterations, self.stepSize,
635-
self.miniBatchFraction, self._model.weights,
636-
regParam=self.regParam, convergenceTol=self.convergenceTol)
635+
self.miniBatchFraction, self._model.weights)
637636

638637
dstream.foreachRDD(update)
639638

python/pyspark/mllib/regression.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -669,7 +669,7 @@ def update(rdd):
669669
self._model = LinearRegressionWithSGD.train(
670670
rdd, self.numIterations, self.stepSize,
671671
self.miniBatchFraction, self._model.weights,
672-
intercept=self._model.intercept, convergenceTol=self.convergenceTol)
672+
self._model.intercept)
673673

674674
dstream.foreachRDD(update)
675675

0 commit comments

Comments
 (0)