This issue is turned out cased by version mismatch between driver(0.9.1) and
server(0.9.0-cdh5.0.1) just now. Other function works fine but combinebykey
before.
Thank you very much for your reply.
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/combinebyke
You asked off-list, and provided a more detailed example there:
val random = new Random()
val testdata = (1 to 1).map(_=>(random.nextInt(),random.nextInt()))
sc.parallelize(testdata).combineByKey[ArrayBuffer[Int]](
(instant:Int)=>{new ArrayBuffer[Int]()},
(bucket:ArrayB
