问题标签 [cassandra-2.1]

我以 IST ( '2015-12-28') 格式将数据从 C# 插入到 Cassandra 集群。但是当我使用cqlsh. 它给了我'2015-12-27 18:30:00+0000'格式。因此，要更改格式，我尝试了一些建议，但未能成功，例如在 cqlshrc 文件中添加 TZ='IST' 。指定 cqlsh 输出时区

那么，如何将时区更改为 IST 并获得这样的值'2015-12-27 05:30:00+0000'。

我正在尝试通过在 cassandra 中插入 60k 行来进行负载测试，几千之后我遇到了以下错误

com.impetus.kundera.KunderaException：org.apache.thrift.transport.TTransportException：读取负帧大小

代码详情

Cassndra 版本：2.1.10

使用的库

我面临从表中删除所有记录的问题。

我可以使用截断表。但是截断会创建数据的快照，这在我的场景中会浪费存储空间。

如果任何节点关闭，截断也会失败。

所以我想知道是否有任何方法可以删除表中的所有记录，而无需创建在节点关闭时有效的快照。

Spring-data-Cassandra 1.3.2.RELEASE 是否支持@UDT ( http://docs.datastax.com/en/developer/java-driver/2.1/java-driver/reference/mappingUdts.html )？如果没有，我该如何为此添加解决方法

谢谢

我用于删除基于索引列的行的当前方法

1. 选择限制为 100 的查询。
2. 如果有行，将所有获取的行一一删除。
3. 刷新实体管理器。
4. 转到步骤 1。

使用 cassandra 2.1.8 和 kundera-cassandra-ds-driver 从 cassandra 获取行。

有什么方法可以从 Kundera 触发删除查询。

我想知道是否有一种简单的方法可以查看我通过 cqlsh 运行的 .cql 脚本中可能存在的任何语法错误？

我已经创建了几个带有大量INSERT语句的脚本来将数据加载到我的 Cassandra 数据库中。为了创建脚本，我使用 notepad++ 进行了查找/替换来准备文件（是的，事后看来我应该刚刚写了一个 Python 脚本）。

我知道在我运行脚本后应该有 7,500 条记录，但只有 7,483 条 - 我怀疑某些INSERT语句的格式不正确（因为我将这些语句组合在一起）但我没有从 cqlsh 得到任何反馈.

现在如何在同一个键空间中定义另一个表？所有示例都只讨论定义一个表。我还尝试像上面一样定义另一个表定义及其列规范，但随后出现以下错误“com.datastax.driver.core.exceptions.InvalidQueryException: Batch too large”

我正在使用 Cassandra 2.1.12 将事件数据存储在列族中。下面是为 .net 创建客户端的 c# 代码，它管理来自 Cassandra 的连接。现在的问题是插入/更新数据的速率非常高。所以，现在假设我在后续请求中增加 Cassandra 中的列值。但正如我所说的插入/更新率非常高。因此，在我的 3 节点集群中，如果我第一次写入列的值是 1，那么在下一个请求中，我将读取该列的值并将其更新为 2。但是如果从其他节点获取的值没有被初始化为 1。然后值将再次存储为 1。所以，现在为了解决这个问题，我也将值保留为consistency1 QUORUM。但问题仍然存在。谁能告诉我可能的解决方案？

设置：1

3 节点 cassandra 集群。每个节点位于具有4 核32 GB RAM、800GB SSD (DISK)、1Gbit/s = 125 MBytes/sec 网络带宽的不同机器上

2 台 cassandra-stress 客户端机器，其配置与上述完全相同。

实验 1：在一台机器上运行一个客户端，创建 1 到 1000 个线程，并且具有 Quorum 的一致性级别，cassandra 节点上的最大网络吞吐量约为 8MBytes/sec，cassandra 节点和客户

实验 2：在两台不同的机器上运行两个客户端，创建 1 到 1000 个线程，具有 Quorum 的一致性级别，cassandra 节点上的最大网络吞吐量约为 12MBytes/sec，cassandra 节点和客户端的 CPU 使用率为 90%

即使我的客户端在两台不同的机器上运行，也没有看到双倍的吞吐量，但我可以理解 cassandra 节点受 CPU 限制，这可能就是原因。这样我就可以进入 setup2

设置 2

3 节点 cassandra 集群。每个节点位于具有8 个内核32 GB RAM、800GB SSD (DISK)、1Gbit/s = 125 MBytes/sec 网络带宽的不同机器上

2 台 cassandra-stress 客户端机器，4 核 32 GB RAM，800GB SSD (DISK)，1Gbit/s = 125 MBytes/sec 网络带宽

实验 3：在一台机器上运行一个客户端，创建 1 到 1000 个线程，并且具有 Quorum 的一致性级别，cassandra 节点上的最大网络吞吐量约为 18MBytes/sec，而 cassandra 节点上的 CPU 使用率为 65-70%，并且 > 90% 在客户端节点上。

实验 4：在两台不同的机器上运行两个客户端，创建 1 到 1000 个线程，并且具有 Quorum 的一致性级别，cassandra 节点上的最大网络吞吐量约为 22MBytes/sec，而 cassandra 节点上的 CPU 使用率 <=75%，并且在两个客户端节点上 >90%。

所以这里的问题是，一个客户端节点我能够推送 18MB/秒（网络吞吐量），而两个客户端节点运行两台不同的机器，我只能以 22MB/秒（网络吞吐量）的峰值推送？我想知道为什么会出现这种情况，即使这次 cassandra 节点上的 cpu 使用率在 8 核机器上约为 65-70%。

注意：我停止了 cassandra，并在两台不同的 ec2 机器上运行了一个名为 iperf3 的工具，我能够看到 118 MBytes/秒的网络带宽。我将所有内容都转换为字节而不是位，以避免任何形式的混淆。

我在卡桑德拉有桌子：

然后我尝试使用查询选择数据：

我找不到这种行为的原因。