diff options
| author | Joseph K. Bradley <joseph@databricks.com> | 2014-11-05 19:51:18 -0800 |
|---|---|---|
| committer | Xiangrui Meng <meng@databricks.com> | 2014-11-05 19:51:26 -0800 |
| commit | ff84a8ae258083423529885d85bf1d939a62d899 (patch) | |
| tree | 72d7df00369bab0154ed315760050b8d95411039 /examples/src/main | |
| parent | 9ac5c517b64606db7d6b8ac3b823c3d5a45e0ed0 (diff) | |
| download | spark-ff84a8ae258083423529885d85bf1d939a62d899.tar.gz spark-ff84a8ae258083423529885d85bf1d939a62d899.tar.bz2 spark-ff84a8ae258083423529885d85bf1d939a62d899.zip | |
[SPARK-4254] [mllib] MovieLensALS bug fix
Changed code so it does not try to serialize Params.
CC: mengxr debasish83 srowen
Author: Joseph K. Bradley <joseph@databricks.com>
Closes #3116 from jkbradley/als-bugfix and squashes the following commits:
e575bd8 [Joseph K. Bradley] Merge remote-tracking branch 'upstream/master' into als-bugfix
9401b16 [Joseph K. Bradley] changed implicitPrefs so it is not serialized to fix MovieLensALS example bug
(cherry picked from commit c315d1316cb2372e90ae3a12f72d5b3304435a6b)
Signed-off-by: Xiangrui Meng <meng@databricks.com>
Diffstat (limited to 'examples/src/main')
| -rw-r--r-- | examples/src/main/scala/org/apache/spark/examples/mllib/MovieLensALS.scala | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/examples/src/main/scala/org/apache/spark/examples/mllib/MovieLensALS.scala b/examples/src/main/scala/org/apache/spark/examples/mllib/MovieLensALS.scala index 8796c28db8..91a0a860d6 100644 --- a/examples/src/main/scala/org/apache/spark/examples/mllib/MovieLensALS.scala +++ b/examples/src/main/scala/org/apache/spark/examples/mllib/MovieLensALS.scala @@ -106,9 +106,11 @@ object MovieLensALS { Logger.getRootLogger.setLevel(Level.WARN) + val implicitPrefs = params.implicitPrefs + val ratings = sc.textFile(params.input).map { line => val fields = line.split("::") - if (params.implicitPrefs) { + if (implicitPrefs) { /* * MovieLens ratings are on a scale of 1-5: * 5: Must see |