Fixed cassandra DS bug by adding port to connection string

This commit is contained in:
Shalom Yerushalmy
2017-06-08 15:44:09 +03:00
parent 6a0bb82f3c
commit 94077ccafd
2 changed files with 2 additions and 0 deletions

View File

@@ -92,9 +92,11 @@ class Cassandra(BaseQueryRunner):
password='{}'.format(self.configuration.get('password', '')))
connection = Cluster([self.configuration.get('host', '')],
auth_provider=auth_provider,
port=self.configuration.get('port', ''),
protocol_version=self.configuration.get('protocol', 3))
else:
connection = Cluster([self.configuration.get('host', '')],
port=self.configuration.get('port', ''),
protocol_version=self.configuration.get('protocol', 3))
session = connection.connect()
session.set_keyspace(self.configuration['keyspace'])

View File