fix bug in master

apache · Oct 25, 2014 · b4292ce · b4292ce
1 parent d79744c
commit b4292ce
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/python/pyspark/mllib/recommendation.py b/python/pyspark/mllib/recommendation.py
@@ -102,13 +102,13 @@ def userFeatures(self):
         sc = self._context
         juf = self._java_model.userFeatures()
         juf = sc._jvm.SerDe.fromTuple2RDD(juf).toJavaRDD()
-        return RDD(sc._jvm.PythonRDD.javaToPython(juf), sc)
+        return RDD(sc._jvm.SerDe.javaToPython(juf), sc)
 
     def productFeatures(self):
         sc = self._context
         jpf = self._java_model.productFeatures()
         jpf = sc._jvm.SerDe.fromTuple2RDD(jpf).toJavaRDD()
-        return RDD(sc._jvm.PythonRDD.javaToPython(jpf), sc)
+        return RDD(sc._jvm.SerDe.javaToPython(jpf), sc)
 
 
 class ALS(object):