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