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

Connecting Cassandra by unknow host

2015-01-29 Thread oxpeople
I have the code set up the Cassandra SparkConf conf = new SparkConf(true); conf.setAppName(Java cassandra RD); conf.set(*spark.cassandra.connection.host, 10.34.224.249*); but I got log try to connect different host. 15/01/29 16:16:42 INFO NettyBlockTransferService: Server created on