2016-06-01 7 views
0

Ich greife auf Hbase mit happybase mit Python.Hbase Timeout Fehler auftreten

Ich habe eine sehr einfache Funktion:

def connect(): 

    connection = happybase.Connection('myhost',myport) 
    table = connection.table('MY-TABLE') 
    try: 
     return str(table.row('my-row')) 
    except Exception as ioe: 
     return str(ioe) 
    finally: 
     connection.close() 

Wenn ich diese Funktion führen Sie es für ein paar Minuten gut funktioniert, dann fange ich Timeout-Fehler bekommen.

Die Lösung besteht darin, in die Hbase-Konsole zu gehen und einen neuen Sparft-Port zu öffnen und darauf zu zeigen.

Das funktioniert wieder für ein paar Minuten und dann bekomme ich wieder die Timeout-Fehler.

Keine gute Lösung, keine Ahnung, warum das passieren könnte?

EDIT

hier Fehler:

`Traceback (most recent call last): 
    File "appi.py", line 38, in <module> 
    print connectx() 
    File "appi.py", line 26, in connectx 
    print str(table.row('1464242429566-2531079631688429')) 
    File "C:\Users\me\Downloads\happybase-master\happybase-master\happybase\table.py", line 116, in row 
    self.name, row, columns, {}) 
    File "C:\Python27\lib\site-packages\thriftpy-0.3.8-py2.7.egg\thriftpy\thrift.py", line 160, in _req 
    return self._recv(_api) 
    File "C:\Python27\lib\site-packages\thriftpy-0.3.8-py2.7.egg\thriftpy\thrift.py", line 172, in _recv 
    fname, mtype, rseqid = self._iprot.read_message_begin() 
    File "C:\Python27\lib\site-packages\thriftpy-0.3.8-py2.7.egg\thriftpy\protocol\binary.py", line 372, in read_message_begin 
    self.trans, strict=self.strict_read) 
    File "C:\Python27\lib\site-packages\thriftpy-0.3.8-py2.7.egg\thriftpy\protocol\binary.py", line 164, in read_message_begin 
    sz = unpack_i32(inbuf.read(4)) 
    File "C:\Python27\lib\site-packages\thriftpy-0.3.8-py2.7.egg\thriftpy\transport\__init__.py", line 32, in read 
    return readall(self._read, sz) 
    File "C:\Python27\lib\site-packages\thriftpy-0.3.8-py2.7.egg\thriftpy\transport\__init__.py", line 14, in readall 
    chunk = read_fn(sz - have) 
    File "C:\Python27\lib\site-packages\thriftpy-0.3.8-py2.7.egg\thriftpy\transport\buffered\__init__.py", line 39, in _read 
    self._rbuf = BytesIO(self._trans.read(max(sz, self._buf_size))) 
    File "C:\Python27\lib\site-packages\thriftpy-0.3.8-py2.7.egg\thriftpy\transport\socket.py", line 108, in read 
    buff = self.sock.recv(sz) 
socket.timeout: timed out` 

Antwort

1

das Timeout erhöhen, indem die Eigenschaft in hbase-site.xml Einstellung, die in verfügbar sein wird hbase/conf

<property> 
    <name>hbase.regionserver.lease.period</name> 
    <value>900000</value> <!-- 900 000, 15 minutes --> 
    </property> 
    <property> 
    <name>hbase.rpc.timeout</name> 
    <value>900000</value> <!-- 15 minutes --> 
    </property> 
<property> 
    <name>zookeeper.session.timeout</name> 
    <value>20000</value> 
</property> 
+0

Ich werde dies versuchen. Aber warum scheint es zu Beginn gut zu funktionieren, und dann läuft es zu 100% ab. Es muss der Fall sein, dass etwas "reparierbar" das verursacht? –

+0

Können Sie bitte. post complete stack trace in Frage es selbst. –

+0

Danke für die Hilfe. Ich habe die Frage bearbeitet –

0

können Sie erhöhen auch die Timeout in der Instanziierung happybase.Connection:

conn = happybase.Connection(server_url, 9090, timeout=100000) 

Es ist eine anerkannte (aber nicht freigegeben) pull request für die Ehrung None als „nie Timeout“