Commit f4cb056d authored by Sebastien Ponce's avatar Sebastien Ponce
Browse files

Close properly hbase connections in case of broken pipe, avoiding socket leak

parent 81606f8e
......@@ -74,6 +74,8 @@ class Pusher(threading.Thread):
def _handle_disconnect(self, exc):
""" Handle a disconnect """
logging.error(str(exc))
if connection:
connection.close()
self._connect()
return
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment