HBase: Thrift写数据报错——socket.error: [Errno 32] Broken pip

博主用的是python来读写hbase

需要安装 pip install thrift 和 pip install hbase-thrift

hbase客户端创建：

from thrift import Thrift
from thrift.transport import TSocket, TTransport
from thrift.protocol import TBinaryProtocol
from hbase import Hbase#server端地址和端口,web是HMaster也就是thriftServer主机名,9090是thriftServer默认端口
transport = TSocket.TSocket('hadoop4’, 9090)
#可以设置超时
transport.setTimeout(5000)
#设置传输方式（TFramedTransport或TBufferedTransport）
trans = TTransport.TBufferedTransport(transport)
#设置传输协议
protocol = TBinaryProtocol.TBinaryProtocol(trans)
#确定客户端
client = Hbase.Client(protocol)
#打开连接
transport.open()

如果，在读写hbase过程中报错：socket.error: [Errno 32] Broken pip，原因大致是因为，数据还没有读写进去，socket已经关闭了，解决办法就是在创建客户端设置超时时间。

#可以设置超时
transport.setTimeout(5000)

或者直接在配置文件conf/hbase-site.xml中添加如下配置（每个节点都添加）：

<property><name>hbase.thrift.server.socket.read.timeout</name><value>6000000</value><description>eg:milisecond</description>
</property>

即设置超时时间为60s。

HBase: Thrift写数据报错——socket.error: [Errno 32] Broken pip相关推荐

页面文件太小，无法解决/BrokenPipeError: [Errno 32] Broken pipe问题解决
跑模型的日子就是天天.天天地改bug,bug天天对我说"爱你",我只想让它滚出地球呜呜呜呜呜呜.为了表达我对它们的"爱意",我一定要把这几天的辛酸泪记录下来! ...
linux socket errno 4,解决socket.error: [Errno 98] Address already in use问题
刚刚开始使用flask框架写了两个小程序.然后我先访问了第一个"Hello,Web"的小程序,运行通过,然后想看看第二个inputname的程序是不是写对,但是linux报错: s ...
python socket.error: [Errno 24] Too many open files
以openwrt AR9331开发板为例,socket连接到1019个就报错 "python socket.error: [Errno 24] Too many open files&quo ...
python socket.error: [Errno 10054] 远程主机强迫关闭了一个现有的连接。问题解决方案
python socket.error: [Errno 10054] 远程主机强迫关闭了一个现有的连接.问题解决方案: 前几天使用python读取网页.因为对一个网站大量的使用urlopen操作,所以 ...
python [Errno socket error] [Errno 104] Connection reset by peer
python [Errno socket error] [Errno 104] Connection reset by peer 原因可能是多方面的,不过更常见的原因是: ①:服务器的并发连接数超过了 ...
python socket.error: [Errno 10054] 解决方法
python socket.error: [Errno 10054] 解决方法参考文章: (1)python socket.error: [Errno 10054] 解决方法 (2)https:// ...
解决只读模式U盘保护格式化或者dd写报错：ERROR: failed to open ‘/dev/sdb‘ in read-write mode: Read-only file system.
解决只读模式U盘保护格式化或者dd写报错:ERROR: failed to open '/dev/sdb' in read-write mode: Read-only file system. 或者: ...
python bad file descriptor_python socket.error: [Errno 9] Bad file descriptor
今天编写一个tcp服务器的时候出现错误:socket.error: [Errno 9] Bad file descriptor 出现的原因是连接已经被关闭,部分语句还在试图调用已经关闭的连接. 代码片 ...
ssh连接失败报错：Socket error Event: 32 Error: 10053.
问题:使用远程连接工具ssh连接局域网内的主机,刚连接成功一会儿就断开连接,报下面的错误信息 Socket error Event: 32 Error: 10053. Connection closi ...

HBase: Thrift写数据报错——socket.error: [Errno 32] Broken pip

HBase: Thrift写数据报错——socket.error: [Errno 32] Broken pip相关推荐

最新文章

热门文章