我有一个单节点集群3.11.6
我首先在airflow任务中编写了由10000列组成的2750行(这是成功传递的)
然后,在我试图连接到Cassandra之后,立即在同一气流DAG的另一组并行任务中执行各种读取,并且在ERROR - ('Unable to connect to any servers', {'10.0.1.135:9042': OperationTimedOut('errors=None, last_host=None')})中失败。
我已经在execution_profiles中配置了重试,但它们似乎是而不是强
我在一个DC中有两个C* 2.0.2节点(在cassandra.yaml中具有默认配置)和一个带有RF=2的密钥空间,两个客户端通过Datastax驱动程序1.0.3连接到这个DC。客户端使用CL=ONE从/向C*读取和写入数据,没有任何错误。但是,当我关闭一个节点时,两个客户端都会得到大量的异常:
com.datastax.driver.core.exceptions.NoHostAvailableException:
All host(s) tried for query failed (no host was tried)
在这些异常之后,客户端继续成功地与另一个仍然活着的节点一起工作。
在医生1中,有人说
if using a write consistency level of QUORUM with a replication factor
of 3, Cassandra will send the write to 2 replicas. If the write fails on
one of the replicas but succeeds on the other, Cassandra will report a
write failure to the client.
因此,假设只有两个副本接收更新,写入失败。但是由于最终的一致性,所有的节点最终都会收到更
我已经能够在Windows本地主机端口上启动Cassandra,并使用cassandra-driver模块连接到它。但是,当我尝试通过Docker容器连接到Cassandra时,我收到以下连接被拒绝的异常:
cassandra.cluster.NoHostAvailable: ('Unable to connect to any servers', {'192.168.99.101': ConnectionRefusedError(10061, "Tried connecting to [('192.168.99.101', 9042)]
在使用Data驱动程序版本1.0.2连接到Cassandra 1.2.1时,我得到了错误:
Exception in thread "main" java.lang.IllegalArgumentException: populate_io_cache_on_flush is not a column defined in this metadata
at com.datastax.driver.core.ColumnDefinitions.getIdx(ColumnDefinitions.java:268)
at com.datastax.driver.core.Row.is
我正在将节点添加到现有的cassandra集群中。在节点流所有数据之后,引导就被卡住了。netstats没有显示流向新节点的数据。当我检查nodetool中的新节点时,它会显示一个异常。这个异常可能是引导失败的原因。
连接节点上的日志文件显示以下异常。但随后的例外并没有停止流。此节点也会在异常后流数据。
在org.apache.cassandra.io.util.FileUtils.skipBytesFully(FileUtils.java:229) at org.apache.cassandra.io.sstable.IndexHelper.skipBloomFilter(IndexHelp
我使用的是cassandra-2.0.3,我已经在数据中心添加了一个新节点(使用vnode),但是在运行nodetool清理时,我得到了
Error occurred during cleanup
java.util.concurrent.ExecutionException: java.lang.ClassCastException: org.apache.cassandra.io.sstable.SSTableReader$EmptyCompactionScanner cannot be cast to org.apache.cassandra.io.sstable.SSTableScan
嗨,有一些问题要从python连接器连接我的cassandra。
Connotor.py包含以下代码
from cassandra.cluster import Cluster
from cassandra.auth import PlainTextAuthProvider
from cassandra import ReadTimeout
import os
class CassandraConnection():
def getConnection():
auth_provider = PlainTextAuthProvider(username ='a
我无法启动DSE搜索的solr方面,当我执行bin/dse cassandra启动时,我会收到以下异常消息:启动cassandra服务,但没有solr,是否有人可以为我提供任何指导,我知道我错过了什么:
bin/dse cassandra -s
电文:
Cannot start node if snitch's data center (Solr) differs from previous data center (Cassandra). Please fix the snitch configuration, decommission and rebootstrap this no
我正在尝试用python编写一个脚本来连接到远程Cassandra DB。我使用的是flask_cqlalchemy。Cassandra设置在具有SSH访问的远程服务器上,当连接到Cassandra时,它提供:
cassandra.cluster.NoHostAvailable: ('Unable to connect to any servers', {'IP:9042': ConnectionRefusedError(61, "Tried connecting to [('IP', 9042)]. Last error: Connec
我在两个节点上有一个cassandra集群。在第3个节点上,我安装了OpsCenter并尝试连接到现有的cassandra集群,问题是当我尝试从OpsCenter连接时,它会抛出下一个:
node1: 172.16.8.232
node2: 172.16.8.233
Node3(不在cassandra集群中):172.16.8.231
Error creating cluster: Unable to connect to cluster. Error is: Unable to connect to any seed nodes, tried [u'172.16.8.232'
起初,我下载了Cassandra3.7,并将其安装在远程计算机上(仍然在同一个网络中),但我想将其作为一个服务运行,所以我下载并安装了DataStax_DDC_Server 3.7.0
但是当我试图远程连接到服务时,我得到了一个错误:Unable to gossip with any seeds,所以我遵循了解决这个问题的几个解决方案。
我不认为这是防火墙或端口问题,因为我可以连接到其他Cassandra数据库。我还从旧的Cassandra环境(正在工作的那个)复制.YAML文件。
我还能做什么呢?我是否必须更改datastax版本中的.yaml文件中的更多内容,而不是直接从下载的版本?