[
https://issues.apache.org/jira/browse/SPARK-5949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14346694#comment-14346694
]
Peter Torok commented on SPARK-5949:
------------------------------------
Hi Imran,
I'm getting the following error if a class is not registered with kryo:
java.lang.IllegalArgumentException: Class is not registered:
org.apache.spark.scheduler.HighlyCompressedMapStatus
Note: To register this class use:
kryo.register(org.apache.spark.scheduler.HighlyCompressedMapStatus.class);
at com.esotericsoftware.kryo.Kryo.getRegistration(Kryo.java:442)
at
com.esotericsoftware.kryo.util.DefaultClassResolver.writeClass(DefaultClassResolver.java:79)
...
In this case, the registrator class needs to be extended by registering the
mentioned class. If more classes are involved this need to be done iteratively
while getting the exception.
Regarding to the PR, I don't see the Array[Long] is registered. If it's
registered elsewhere, it's fine. If not, it should be added.
Thanks,
Peter
> Driver program has to register roaring bitmap classes used by spark with Kryo
> when number of partitions is greater than 2000
> ----------------------------------------------------------------------------------------------------------------------------
>
> Key: SPARK-5949
> URL: https://issues.apache.org/jira/browse/SPARK-5949
> Project: Spark
> Issue Type: Bug
> Components: Spark Core
> Affects Versions: 1.2.0
> Reporter: Peter Torok
> Assignee: Imran Rashid
> Labels: kryo, partitioning, serialization
> Fix For: 1.4.0
>
>
> When more than 2000 partitions are being used with Kryo, the following
> classes need to be registered by driver program:
> - org.apache.spark.scheduler.HighlyCompressedMapStatus
> - org.roaringbitmap.RoaringBitmap
> - org.roaringbitmap.RoaringArray
> - org.roaringbitmap.ArrayContainer
> - org.roaringbitmap.RoaringArray$Element
> - org.roaringbitmap.RoaringArray$Element[]
> - short[]
> Our project doesn't have dependency on roaring bitmap and
> HighlyCompressedMapStatus is intended for internal spark usage. Spark should
> take care of this registration when Kryo is used.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
