change ser/de of JavaArray and JavaList

apache · Jan 15, 2016 · 4e8df6c · 4e8df6c
1 parent d0a5c32
commit 4e8df6c
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/python/pyspark/mllib/common.py b/python/pyspark/mllib/common.py
@@ -107,10 +107,7 @@ def _java2py(sc, r, encoding="bytes"):
         if clsName in _picklable_classes:
             r = sc._jvm.SerDe.dumps(r)
         elif isinstance(r, (JavaArray, JavaList)):
-            try:
-                r = sc._jvm.SerDe.dumps(r)
-            except Py4JJavaError:
-                pass  # not pickable
+            r = list(r)
 
     if isinstance(r, (bytearray, bytes)):
         r = PickleSerializer().loads(bytes(r), encoding=encoding)