I am using CDH5 on a three machines cluster. map data from hbase as (string,
V) pair , then call combineByKey like this:
.combineByKey[C](
(v:V)=>new C(v), //this line throw java.lang.ClassCastException: C
cannot be cast to V
(v:C,v:V)=>C,
(c1:C,c2:C)=>C)
I am very confused of this, there isn't C to V casting at all. What's
wrong?
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/combinebykey-throw-classcastexception-tp6059.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
