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
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
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