<?xml version="1.0" encoding="UTF-8"?>
<rss xmlns:content="http://purl.org/rss/1.0/modules/content/" xmlns:dc="http://purl.org/dc/elements/1.1/" xmlns:rdf="http://www.w3.org/1999/02/22-rdf-syntax-ns#" xmlns:taxo="http://purl.org/rss/1.0/modules/taxonomy/" version="2.0">
  <channel>
    <title>question Not able to connect to hiveserver2  to access hivetables with python in Support Questions</title>
    <link>https://community.cloudera.com/t5/Support-Questions/Not-able-to-connect-to-hiveserver2-to-access-hivetables-with/m-p/270635#M207457</link>
    <description>&lt;P&gt;Can somebody please help me in connecting to hiveserver2 with python 2.7.5?&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;hive-site.xml contains&lt;/P&gt;&lt;P&gt;-------------------------------&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;&amp;lt;property&amp;gt;&lt;BR /&gt;&amp;lt;name&amp;gt;hive.server2.transport.mode&amp;lt;/name&amp;gt;&lt;BR /&gt;&amp;lt;value&amp;gt;http&amp;lt;/value&amp;gt;&lt;BR /&gt;&amp;lt;description&amp;gt;IP address (or fully-qualified domain name) and port of the metastore host&amp;lt;/description&amp;gt;&lt;BR /&gt;&amp;lt;/property&amp;gt;&lt;BR /&gt;&amp;lt;property&amp;gt;&lt;BR /&gt;&amp;lt;name&amp;gt;hive.server2.thrift.http.port&amp;lt;/name&amp;gt;&lt;BR /&gt;&amp;lt;value&amp;gt;10001&amp;lt;/value&amp;gt;&lt;BR /&gt;&amp;lt;/property&amp;gt;&lt;BR /&gt;&amp;lt;property&amp;gt;&lt;BR /&gt;&amp;lt;name&amp;gt;hive.server2.thrift.http.path&amp;lt;/name&amp;gt;&lt;BR /&gt;&amp;lt;value&amp;gt;cliservice&amp;lt;/value&amp;gt;&lt;BR /&gt;&amp;lt;/property&amp;gt;&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;&amp;lt;property&amp;gt;&lt;BR /&gt;&amp;lt;name&amp;gt;hive.server2.authentication&amp;lt;/name&amp;gt;&lt;BR /&gt;&amp;lt;value&amp;gt;NOSASL&amp;lt;/value&amp;gt;&lt;BR /&gt;&amp;lt;/property&amp;gt;&lt;BR /&gt;&amp;lt;property&amp;gt;&lt;BR /&gt;&amp;lt;name&amp;gt;hive.server2.thrift.bind.host&amp;lt;/name&amp;gt;&lt;BR /&gt;&amp;lt;value&amp;gt;localhost&amp;lt;/value&amp;gt;&lt;BR /&gt;&amp;lt;/property&amp;gt;&lt;BR /&gt;&amp;lt;property&amp;gt;&lt;/P&gt;&lt;P&gt;&amp;lt;name&amp;gt;hive.metastore.uris&amp;lt;/name&amp;gt;&lt;BR /&gt;&amp;lt;value&amp;gt;thrift://localhost:9083&amp;lt;/value&amp;gt;&lt;BR /&gt;&amp;lt;/property&amp;gt;&lt;BR /&gt;&amp;lt;property&amp;gt;&lt;BR /&gt;&amp;lt;name&amp;gt;hive.metastore.event.db.notification.api.auth&amp;lt;/name&amp;gt;&lt;BR /&gt;&amp;lt;value&amp;gt;false&amp;lt;/value&amp;gt;&lt;BR /&gt;&amp;lt;/property&amp;gt;&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;Using beeline&lt;/P&gt;&lt;P&gt;----------------&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;./beeline&lt;BR /&gt;SLF4J: Class path contains multiple SLF4J bindings.&lt;BR /&gt;SLF4J: Found binding in [jar:file:/opt/hive/lib/log4j-slf4j-impl-2.10.0.jar!/org/slf4j/impl/StaticLoggerBinder.class]&lt;BR /&gt;SLF4J: Found binding in [jar:file:/opt/hadoop-2.7.3/share/hadoop/common/lib/slf4j-log4j12-1.7.10.jar!/org/slf4j/impl/StaticLoggerBinder.class]&lt;BR /&gt;SLF4J: See &lt;A href="http://www.slf4j.org/codes.html#multiple_bindings" target="_blank"&gt;http://www.slf4j.org/codes.html#multiple_bindings&lt;/A&gt; for an explanation.&lt;BR /&gt;SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]&lt;BR /&gt;Beeline version 3.1.2 by Apache Hive&lt;BR /&gt;beeline&amp;gt; &lt;STRONG&gt;!connect jdbc:hive2://127.0.0.1:10001/default;auth=noSasl hive hive&lt;/STRONG&gt;&lt;BR /&gt;&lt;STRONG&gt;Connecting to jdbc:hive2://127.0.0.1:10001/default;auth=noSasl&lt;/STRONG&gt;&lt;BR /&gt;Java heap space&lt;BR /&gt;0: jdbc:hive2://127.0.0.1:10001/default (closed)&amp;gt; Connection is already closed.&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;With Pyhive&lt;/P&gt;&lt;P&gt;------------&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;conn = hive.Connection(host='127.0.0.1', port=10002, username='hive', password='hive',&lt;BR /&gt;database='default', auth='CUSTOM'). // tried&amp;nbsp;auth ='CUSTOM'/'NOSASL'&lt;BR /&gt;cur = conn.cursor()&lt;BR /&gt;cur.execute('select * from employee limit 5')&lt;BR /&gt;result = cur.fetchall()&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;File "connect_hive.py", line 47, in &amp;lt;module&amp;gt;&lt;BR /&gt;output = hiveconnection(host_name, port, user,password, database)&lt;BR /&gt;File "connect_hive.py", line 29, in hiveconnection&lt;BR /&gt;database=database, auth='CUSTOM')&lt;BR /&gt;File "/usr/lib/python2.7/site-packages/pyhive/hive.py", line 192, in __init__&lt;BR /&gt;self._transport.open()&lt;BR /&gt;File "/usr/lib/python2.7/site-packages/thrift_sasl/__init__.py", line 80, in open&lt;BR /&gt;status, payload = self._recv_sasl_message()&lt;BR /&gt;File "/usr/lib/python2.7/site-packages/thrift_sasl/__init__.py", line 101, in _recv_sasl_message&lt;BR /&gt;payload = read_all_compat(self._trans, length)&lt;BR /&gt;File "/usr/lib/python2.7/site-packages/thrift_sasl/six.py", line 31, in &amp;lt;lambda&amp;gt;&lt;BR /&gt;read_all_compat = lambda trans, sz: trans.readAll(sz)&lt;BR /&gt;File "/usr/lib64/python2.7/site-packages/thrift/transport/TTransport.py", line 60, in readAll&lt;BR /&gt;chunk = self.read(sz - have)&lt;BR /&gt;File "/usr/lib64/python2.7/site-packages/thrift/transport/TSocket.py", line 132, in read&lt;BR /&gt;message='TSocket read 0 bytes')&lt;BR /&gt;&lt;STRONG&gt;thrift.transport.TTransport.TTransportException: TSocket read 0 byte&lt;/STRONG&gt;&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;using pyhs2&lt;/P&gt;&lt;P&gt;-------------&lt;/P&gt;&lt;P&gt;pyhs2.connect(host='localhost',port=10002, authMechanism="NOSASL", user='hive',password='hive',database='default')&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;&lt;BR /&gt;Traceback (most recent call last):&lt;BR /&gt;File "&amp;lt;stdin&amp;gt;", line 1, in &amp;lt;module&amp;gt;&lt;BR /&gt;File "/usr/lib/python2.7/site-packages/pyhs2/__init__.py", line 7, in connect&lt;BR /&gt;return Connection(*args, **kwargs)&lt;BR /&gt;File "/usr/lib/python2.7/site-packages/pyhs2/connections.py", line 47, in __init__&lt;BR /&gt;res = self.client.OpenSession(TOpenSessionReq(username=user, password=password, configuration=configuration))&lt;BR /&gt;File "/usr/lib/python2.7/site-packages/pyhs2/TCLIService/TCLIService.py", line 154, in OpenSession&lt;BR /&gt;return self.recv_OpenSession()&lt;BR /&gt;File "/usr/lib/python2.7/site-packages/pyhs2/TCLIService/TCLIService.py", line 165, in recv_OpenSession&lt;BR /&gt;(fname, mtype, rseqid) = self._iprot.readMessageBegin()&lt;BR /&gt;File "/usr/lib64/python2.7/site-packages/thrift/protocol/TBinaryProtocol.py", line 148, in readMessageBegin&lt;BR /&gt;name = self.trans.readAll(sz)&lt;BR /&gt;File "/usr/lib64/python2.7/site-packages/thrift/transport/TTransport.py", line 60, in readAll&lt;BR /&gt;chunk = self.read(sz - have)&lt;BR /&gt;File "/usr/lib64/python2.7/site-packages/thrift/transport/TTransport.py", line 162, in read&lt;BR /&gt;self.__rbuf = BufferIO(self.__trans.read(max(sz, self.__rbuf_size)))&lt;BR /&gt;File "/usr/lib64/python2.7/site-packages/thrift/transport/TSocket.py", line 132, in read&lt;BR /&gt;message='TSocket read 0 bytes')&lt;BR /&gt;&lt;STRONG&gt;thrift.transport.TTransport.TTransportException: TSocket read 0 bytes&lt;/STRONG&gt;&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;</description>
    <pubDate>Fri, 13 Sep 2019 09:36:54 GMT</pubDate>
    <dc:creator>ranger</dc:creator>
    <dc:date>2019-09-13T09:36:54Z</dc:date>
  </channel>
</rss>

