You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@toree.apache.org by "Alexander Anokhin (JIRA)" <ji...@apache.org> on 2018/02/06 13:26:00 UTC
[jira] [Created] (TOREE-464) Failing actions on RDDs with
non-primitive objects
Alexander Anokhin created TOREE-464:
---------------------------------------
Summary: Failing actions on RDDs with non-primitive objects
Key: TOREE-464
URL: https://issues.apache.org/jira/browse/TOREE-464
Project: TOREE
Issue Type: Bug
Affects Versions: 0.2.0
Reporter: Alexander Anokhin
Attachments: test_case.ipynb
Running in non local mode actions on RDDs fail when RDDs hold custom non-primitive objects. It affects current master version 0.3.0 (https://github.com/apache/incubator-toree) as well as released versions RC1 (https://github.com/apache/incubator-toree/releases/tag/v0.2.0-incubating-rc1), RC2 (https://github.com/apache/incubator-toree/releases/tag/v0.2.0-incubating-rc2) and RC3 (https://github.com/apache/incubator-toree/releases/tag/v0.2.0-incubating-rc3).
Example:
```
Cell 1: case class A(i: Int)
Cell 2: val events = sc.parallelize((1 to 5).toSeq).map \{ i => A(i) }
Cell 3: println(events.count())
results "java.lang.NoClassDefFoundError: Could not initialize class ..."
```
However, it does work if code from the cells 1 and 2 is combined into one cell. In that case actions on such RDDs work correctly, but case class definition should be added to every cell with problem RDD.
Example:
```
Cell 1: case class A(i: Int)
val events = sc.parallelize((1 to 5).toSeq).map \{ i => A(i) }
Cell 2: println(events.count())
results "5"
```
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)