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

python-phoenixdb version for phoenix4.13 #6

@krjwpark

Description

@krjwpark

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("''",))

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions