17/04/01 09:15:07 ERROR LiveListenerBus: Listener EventLoggingListener threw an exception
java.io.IOException: Lease timeout of 0 seconds expired.
使用spark streaming 访问kafka 拿到数据插入hbase中,并且有checkpoint
当天程序没有问题,过了一天后,程序开始抛最上面的异常
检查了hbase数据插入没有异常,
初步排查是checkpoint的租约过期
所以将sparkstreaming的 窗口时间减少到59秒
看看情况再说。
最后
以上就是安详糖豆最近收集整理的关于Lease timeout of 0 seconds expired. 租约过期的全部内容,更多相关Lease内容请搜索靠谱客的其他文章。
本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
发表评论 取消回复