logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

quorum.QuorumCnxManager: Connection broken for id 1, my id = 2, error = java.net.SocketException:

在研究hbase,所以暂时使用的HBase自带的zookeeper + 伪分布式,在一次网络问题导致IP更改后,出现了不能create table 的错误,于是看log发现启动hbase时出现如下error: quorum.QuorumCnxManager: Connection broken for id 1, my id = 2, error =  java.net.SocketExcepti

Spark Stream 消费 Kafka 踩坑

在有网络并发基础和大数据框架算法基础情况下,算法和理解源码并不是最耗时的(大概),因为如果首次自己搭建火花在卡夫卡消费应用框架,并且缺乏可执行演示情况下,总会莫名其妙出现一些奇怪问题。很容易可以写出一个SparkStreaming消费卡夫卡的简单的java的的样例,但奇怪的是本地调试集群总是通不过,检查发现程序莫名被停止,但控制台在决定停止之前并没有抛出异常查看Spark Web ...

到底了