Testing spark-testing-base. Error multiple SparkContext

2018-04-03 Thread Guillermo Ortiz
I'm doing a spark test with spark streaming, cassandra and kafka. I have an action which has an DStream as input and save to Cassandra and sometimes put some elements in Kafka. I'm using https://github.com/holdenk/spark-testing-base and kafka y cassandra in local. My method looks like: *def

Re: Base ERROR

2015-12-17 Thread Jeff Zhang
I believe this is hbase issue, you'd better to ask on hbase mail list. On Fri, Dec 18, 2015 at 9:57 AM, censj wrote: > hi,all: > I wirte data to hbase,but Hbase arise this ERROR,Could you help me? > > > r.KeeperException$SessionExpiredException: KeeperErrorCode =

Base ERROR

2015-12-17 Thread censj
hi,all: I wirte data to hbase,but Hbase arise this ERROR,Could you help me? > > r.KeeperException$SessionExpiredException: KeeperErrorCode = Session expired > for /hbase-unsecure/rs/byd0157,16020,1449106975377 > 2015-12-17 21:24:29,854 WARN [regionserver/byd0157/192.168.0.157:16020] >