问题标签 [cassandra-cluster]

我正在尝试在四个 EC2t2.2xlarge节点上设置 Cassandra 集群，其中一个节点被指定为种子。集群似乎已在每个节点上启动。但是，当我尝试运行 /opt/cassandra/bin/cqlsh 时，出现以下错误：

当我9042在种子节点上执行 netstat 时，我得到以下输出：

我在想这个主机地址可能是问题的根源，但不知道它是如何设置的，或者如何改变它。应该是127.0.0.1还是localhost？

我有一个安全组设置，其中包含端口 9042 的以下信息：

也许这里的来源有问题？应该是这个localhost还是什么？

以下是cassandra.yaml我在每个节点上更改的值：

当我启动每个节点时，日志中的最终消息是：

种子节点日志的最后几行是：

因此，其他非种子节点 ( 172.xx.xx.222/333/444) 的每个 IP 似乎都报告为UP. 种子节点 ( 172.xx.xx.111) 仅报告为state jump to NORMAL。

我是 cassandra 的新手，我想使用 cassandra python 客户端进行查询？我无法转义特殊字符。任何人都可以帮忙下面是我正在尝试的查询，但出现语法错误

从化学中选择 pmid 提到=$$ N,N'-((1Z,3Z)-1,4-bis(4-methoxyphenyl)buta-1,3-diene-2,3-diyl)diformamide $$ AND pmid =31134000 允许过滤；

它给了我错误来自服务器的错误：code=2000 [CQL 查询中的语法错误] message="line 1:118 mismatched input '-' Expecting ')' (...,source) VALUES ('be75372a-c311-11e9 -ac2c-0a0df85af938','N,N'[-]...)"

将 cassandra 的 java 驱动程序从 3.7 升级到 4.0（或更高版本）后 - 我无法解析集群名称。

我需要我的应用程序使用 java 驱动程序连接到的 cassandra 集群的名称。早些时候，它以“Cluster.getMetadata().getClusterName()”的形式提供。但升级到 datastax-driver-core-4.0 或更高版本后，我无法从 CqlSession.getMetadata() 解析集群名称。

这非常重要，因为我已经根据不同的集群进行了隔离操作。

我们在 AWS 上使用 EC2Snitch 有一个具有 3 个节点和复制因子 3 的 Cassandra 集群。

实例类型为 c5.2xlarge（8 核和 16GB RAM）。

集群一直运行良好，但突然从昨天晚上开始，所有节点上的 cassandra 进程开始崩溃。它们被设置为自动重新启动，但在启动后 1 或 2 或 3 分钟内它们会因内存堆空间不足错误而崩溃。

堆配置：

在此之后，我们尝试将节点大小增加到 r5.4x 或 128 GB 内存并分配 64GB 堆，但仍然发生相同的事情，无论启动所有 3 个节点还是一次仅启动一个节点。我们可以注意到，第一次垃圾收集在一段时间后发生，然后在几秒钟内连续发生，无法释放任何进一步的内存并最终崩溃。

我们不确定启动后立即将哪些内容拉入内存。

其他参数：

• 卡桑德拉版本：2.2.13
• 数据库大小为 250GB
• hinted_handoff_enabled: true
• commitlog_segment_size_in_mb: 64
• memtable_allocation_type: offheap_buffers

任何帮助在这里，将不胜感激。

编辑： 我们发现查询时有特定的表，它会导致 casssandra 节点崩溃。

所以我们认为，这与这个特定表中的数据损坏/巨大有关。谢谢。

我正在尝试动态创建一个 cassandra 集群。

通常我会创建一个 casssandra 集群，例如：

但这会导致在加载应用程序上下文时（在启动期间）创建 bean。

我如何使用类似于 GenericBeanDefinition 注册的东西来实现相同的目的，并在需要时使用主机名、端口等自定义道具创建 bean？

我最终想要实现的是一种回退机制，如果默认集群无法连接，那么只有新的集群 bean 才会使用自定义道具创建/注册。