RE: get null potiner exception newAPIHadoopRDD.map()

2015-02-06 Thread Sun, Vincent Y
Thanks. The data is there, I have checked the row count and dump to file. -Vincent From: Ted Yu [mailto:yuzhih...@gmail.com] Sent: Thursday, February 05, 2015 2:28 PM To: Sun, Vincent Y Cc: user Subject: Re: get null potiner exception newAPIHadoopRDD.map() Is it possible that value.get

Re: get null potiner exception newAPIHadoopRDD.map()

2015-02-05 Thread Ted Yu
Is it possible that value.get("(area_code")) or value.get("time_zone")) returned null ? On Thu, Feb 5, 2015 at 10:58 AM, oxpeople wrote: > I modified the code Base on CassandraCQLTest. to get the area code count > base on time zone. I got error on create new map Rdd. Any helping is > appreciate

get null potiner exception newAPIHadoopRDD.map()

2015-02-05 Thread oxpeople
I modified the code Base on CassandraCQLTest. to get the area code count base on time zone. I got error on create new map Rdd. Any helping is appreciated. Thanks. ... val arecodeRdd = sc.newAPIHadoopRDD(job.getConfiguration(), classOf[CqlPagingInputFormat], classOf[java.util.Map[Str