Skip to content
This repository has been archived by the owner on Dec 18, 2021. It is now read-only.

python-phoenixdb version for phoenix4.13 #6

Open
krjwpark opened this issue Sep 20, 2018 · 1 comment
Open

python-phoenixdb version for phoenix4.13 #6

krjwpark opened this issue Sep 20, 2018 · 1 comment

Comments

@krjwpark
Copy link

krjwpark commented Sep 20, 2018

Hello, I`m trying to get connect to phoenix server, phoenix version is 4.13(And spark(2.3.0,+pyspark) Hbase(1.2) are used, python version is 2.7.5). With the newest version(v.0.7) for python-phoenixdb, and I got "RPC request failed" error(However, server is working).

According to changelog, v.0.7 covers phoenix 4.8 to 4.11, but I`m wondering there is any compatibility solution for phoenix 4.13.

Thanks,

Follow are my code and entire error message.

import phoenixdb
import phoenixdb.cursor

database_url = 'http://localhost:12345/xxxx'
conn = phoenixdb.connect(database_url, autocommit=True)
---------------------------------------------------------------------------
InterfaceError                            Traceback (most recent call last)
<ipython-input-1-abddd0c12576> in <module>()
      3 
      4 database_url = 'http://localhost:12345:/xxxx'
----> 5 conn = phoenixdb.connect(database_url, autocommit=True)

/usr/lib/python2.7/site-packages/phoenixdb/__init__.pyc in connect(url, max_retries, **kwargs)
     65     client = AvaticaClient(url, max_retries=max_retries)
     66     client.connect()
---> 67     return Connection(client, **kwargs)

/usr/lib/python2.7/site-packages/phoenixdb/connection.pyc in __init__(self, client, cursor_factory, **kwargs)
     54             else:
     55                 self._filtered_args[k] = kwargs[k]
---> 56         self.open()
     57         self.set_session(**self._filtered_args)
     58 

/usr/lib/python2.7/site-packages/phoenixdb/connection.pyc in open(self)
     71         """Opens the connection."""
     72         self._id = str(uuid.uuid4())
---> 73         self._client.open_connection(self._id, info=self._connection_args)
     74 
     75     def close(self):

/usr/lib/python2.7/site-packages/phoenixdb/avatica.pyc in open_connection(self, connection_id, info)
    327                 request.info[k] = v
    328 
--> 329         response_data = self._apply(request)
    330         response = responses_pb2.OpenConnectionResponse()
    331         response.ParseFromString(response_data)

/usr/lib/python2.7/site-packages/phoenixdb/avatica.pyc in _apply(self, request_data, expected_response_type)
    205         headers = {'content-type': 'application/x-google-protobuf'}
    206 
--> 207         response = self._post_request(body, headers)
    208         response_body = response.read()
    209 

/usr/lib/python2.7/site-packages/phoenixdb/avatica.pyc in _post_request(self, body, headers)
    184                     retry_count -= 1
    185                     continue
--> 186                 raise errors.InterfaceError('RPC request failed', cause=e)
    187             else:
    188                 if response.status == httplib.SERVICE_UNAVAILABLE:

InterfaceError: ('RPC request failed', None, None, BadStatusLine("''",))
@nciefeiniu
Copy link

My current version of Phoenix is 4.14,resulting in some errors

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants