我收到以下错误:
File "clear-domain-cass.py", line 25, in <module>
session = cluster.connect('my_domain')
File "/usr/lib/python2.6/dist-packages/cassandra/cluster.py", line 839, in connect
self.control_connection.connect()
File "/usr/lib/python2.6/dist-packages/cassandra/cluster.py", line 2075, in connect
self._set_new_connection(self._reconnect_internal())
File "/usr/lib/python2.6/dist-packages/cassandra/cluster.py", line 2110, in _reconnect_internal
raise NoHostAvailable("Unable to connect to any servers", errors)
cassandra.cluster.NoHostAvailable: ('Unable to connect to any servers', {'10.1.0.89': ConnectionException(u'Failed to initialize new connection to 10.1.0.89: code=0000 [Server error] message="io.netty.handler.codec.DecoderException: org.apache.cassandra.transport.ProtocolException: Invalid or unsupported protocol version: 4"',)})
这是脚本的相关部分:
from cassandra.cluster import Cluster
from cassandra.query import BatchStatement
startTime = time.time()
if len(sys.argv) < 2: …