[SPARK-10959] [PYSPARK] StreamingLogisticRegressionWithSGD does not train with given regParam and StreamingLinearRegressionWithSGD intercept param is not in correct position

Author: BryanCutler

python/pyspark/mllib/classification.py

@@ -632,7 +632,8 @@ def update(rdd):
             if not rdd.isEmpty():
                 self._model = LogisticRegressionWithSGD.train(
                     rdd, self.numIterations, self.stepSize,
-                    self.miniBatchFraction, self._model.weights)
+                    self.miniBatchFraction, self._model.weights,
+                    regParam=self.regParam  )
 
         dstream.foreachRDD(update)
 

python/pyspark/mllib/regression.py

@@ -669,7 +669,7 @@ def update(rdd):
                 self._model = LinearRegressionWithSGD.train(
                     rdd, self.numIterations, self.stepSize,
                     self.miniBatchFraction, self._model.weights,
-                    self._model.intercept)
+                    intercept=self._model.intercept)
 
         dstream.foreachRDD(update)