[Backlogmanager] [FIWARE-JIRA] (HELP-8750) [fiware-stackoverflow] Fiware Cosmos Hive connection with Python

[Fernando Lopez (JIRA)]

     [ https://jira.fiware.org/browse/HELP-8750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Fernando Lopez reassigned HELP-8750:
------------------------------------

    Assignee: Francisco Romero

> [fiware-stackoverflow] Fiware Cosmos Hive connection with Python
> ----------------------------------------------------------------
>
>                 Key: HELP-8750
>                 URL: https://jira.fiware.org/browse/HELP-8750
>             Project: Help-Desk
>          Issue Type: Monitor
>          Components: FIWARE-TECH-HELP
>            Reporter: Backlog Manager
>            Assignee: Francisco Romero
>              Labels: fiware, fiware-cosmos
>
> Created question in FIWARE Q/A platform on 07-09-2016 at 13:09
> {color: red}Please, ANSWER this question AT{color} https://stackoverflow.com/questions/39369236/fiware-cosmos-hive-connection-with-python
> +Question:+
> Fiware Cosmos Hive connection with Python
> +Description:+
> I´m trying to send Hive queries to Fiware Cosmos using the following Python code:
> with pyhs2.connect(host='cosmos.lab.fiware.org',port=10000,
>                                                 authMechanism="PLAIN",
>                                                 user='xxx',
>                                                 password="xxx",
>                                                 database ="xxx" ) as conn: 
>                     print ("pyhs --- %s seconds ---" % ( time.time() - start_time))
>                     with conn.cursor() as cur:
>                             print ("conn ok --- %s seconds ---" % ( time.time() - start_time))
>                             cur.execute("add JAR /usr/local/apache-hive-0.13.0-bin/lib/json-serde-1.3.1-SNAPSHOT-jar-with-dependencies.jar")
> but i get the following error:
> raceback (most recent call last):
> File "script2.py", line 40, in <module>
> database ="default" ) as conn: 
> File "/usr/local/lib/python2.7/site-packages/pyhs2/__init__.py", line 7, in connect
> return Connection(*args, **kwargs)
> File "/usr/local/lib/python2.7/site-packages/pyhs2/connections.py", line 46, in __init__
> transport.open() 
> File "/usr/local/lib/python2.7/site-packages/pyhs2/cloudera/thrift_sasl.py", line 74, in open
> status, payload = self._recv_sasl_message()
> File "/usr/local/lib/python2.7/site-packages/pyhs2/cloudera/thrift_sasl.py", line 92, in _recv_sasl_message
> header = self._trans.readAll(5)
> File "/usr/local/lib64/python2.7/site-packages/thrift/transport/TTransport.py", line 58, in readAll
> chunk = self.read(sz - have)
> File "/usr/local/lib64/python2.7/site-packages/thrift/transport/TSocket.py", line 105, in read
> buff = self.handle.recv(sz)
> socket.error: [Errno 104] Connection reset by peer
> Two months ago I could connect with the same code. Any changes or solution?
> Thanks in advance.



--
This message was sent by Atlassian JIRA
(v6.4.1#64016)