问题标签 [cassandra-2.1]

我们在两个不同的时区有两个不同的 cassandra 集群。

• Cluster1：2.1.8版本，带IST TZ
• Cluster2：2.1.9 版本，带 UTC TZ

在 cluster1 上，对于带有时间戳列的选择查询，我不需要提及 tz[+0530] 值，而在另一个集群上，我必须并且应该在选择查询中提供 TZ 值来获取行。它与cassandra版本有关吗？

我使用 cqlsh 来做查询部分。我尝试了 cqlshrc 文件选项，它只会改变输出的格式。

集群1：

集群2：

如果没有提到 TZ，我得到“0”行。我不想在 cluster2 中给 TZ，请告知如何做到这一点。

我是新来的火花。我正在尝试使用 spark-cassandra 连接器将 csv 文件插入到 cassandra 表中，如下所示：文件位于 Hdfs 中，我正在获取所有文件的路径，并且对于每个路径，我调用一个方法，该方法将 csv 数据转换为对应的 cassandra 数据类型并创建准备好的语句将数据绑定到准备好的语句并将其添加到批处理中。最后我在批处理 1000 时执行。 要点 1. 我使用的是 Apache Cassandra 2.1.8 和 Spark 1.5 2. 我使用 Spark Context 3 读取 Csv 文件。我使用的是 com.datastax.spark.connector.cql。 CassandraConnector 创建与 Cassandra 的会话。

我有 9 个文件，每个文件数据都放在 cassandra 中的一个表中。一切正常所有插入都按预期进行，当我在 spark 提交上提交 jar 时，工作完成。

我面临的问题是当通过 Web 服务调用同一个 Jar 时（Web 服务调用脚本来调用 jar）其中一个文件数据没有被插入并且 spark 上下文没有停止，因此工作永远在运行。

当我插入 4 个文件或 5 个文件时，即使通过 Web 服务也一切正常。但总的来说它挂了，我在其中一张表中少了 10 条记录，而且上下文并没有停止。

这很奇怪，因为当我直接在 spark 提交上提交 jar 时，一切正常，通过 web 服务我遇到了这个问题，奇怪的是，即使 web 服务将作业提交给同一个 spark 提交。

这是我的代码

谁能告诉我导致此问题的原因以及如何解决。谢谢

我有一个患者表和治疗患者，其中 pat_id 充当外键。我想执行一个查询，使treatment_patient 始终返回按pat_id 排序的值。我尝试添加 WITH CLUSTERING ORDER BY (patid ASC); 最后但没有工作。

插入患者：

Treatment_Patients 表：

插入治疗_患者；

输出：

(5 行)

我正在将 csv 文件复制到 cassandra。我有下面的 csv 文件，表的创建如下。

CREATE TABLE UCBAdmissions（
id int PRIMARY KEY，
admit text，
dept text，
freq int，
gender text
）

1. 当我使用

   从 'UCBAdmissions.csv' 复制 UCBAdmissions，DELIMITER = ',' AND HEADER = TRUE;

输出是
0.318 秒内导入的 24 行。
cqlsh> select *from UCBAdmissions;

编号 | 承认 | 部门 | 频率 | 性别
----+-------+------+------+--------

(0 行)

2. 复制 UCBAdmissions(id,admit,gender, dept , freq ) from 'UCBAdmissions.csv' WITH DELIMITER = ',' AND HEADER = TRUE;

输出是
在 0.364 秒内导入的 24 行。
cqlsh> select *from UCBAdmissions;

编号 | 承认 | 部门 | 频率 | 性别
----+----------+------+------+--------
23 | 录取 | F | 24 | 女
5 | 录取 | 乙| 353 | 男
10 | 拒绝 | C | 205 | 男
16 | 拒绝 | D | 244 | 女
13 | 录取 | D | 138 | 男
11 | 录取 | C | 202 | 女
1 | 录取 | 一个 | 512 | 男
19 | 录取 | E | 94 | 女
8 | 拒绝 | 乙| 8 | 女
2 | 拒绝 | 一个 | 313 | 男
4 | 拒绝 | 一个 | 19 | 女
18 | 拒绝 | E | 138 | 男
15 | 录取 | D | 131 | 女
22 | 拒绝 | F | 351 | 男性
20 | 拒绝 | E | 299 | 女
7 | 录取 | 乙| 17 | 女
6 | 拒绝 | 乙| 207 | 男
9 | 录取 | C | 120 | 男
14 | 拒绝 | D | 279 | 男
21 | 录取 | F | 22 | 男
17 | 录取 | E | 53 | 男
24 | 拒绝 | F | 317 | 女
12 | 拒绝 | C | 391 | 女
3 | 录取 | 一个 | 89 | 女性

UCBAdmissions.csv

"","录取","性别","部门","频率"
"1","录取","男","A",512
"2","拒绝","男","A" ,313
"3","录取","女","A",89
"4","拒绝","女","A",19
"5","录取","男","B ",353
"6","拒绝","男性","B",207
"7","录取","女性","B",17
"8","拒绝","女性"," B",8
"9","录取","男","C",120
"10","拒绝","男性","C",205
"11","录取","女性","C",202
"12","拒绝","女性","C",391
"13", "录取","男","D",138
"14","拒绝","男","D",279
"15","录取","女","D",131
"16" ,"拒绝","女性","D",244
"17","录取","男性","E",53
"18","拒绝","男性","E",138202 “12”，“拒绝”，“女性”，“C”，391 “13”，“录取”，“男性”，“D”，138 “14”，“拒绝”，“男性”，“D” ,279 "15","录取","女性","D",131 "16","拒绝","女性","D",244 "17","录取","男性","E ",53 "18","拒绝","男","E",138202 “12”，“拒绝”，“女性”，“C”，391 “13”，“录取”，“男性”，“D”，138 “14”，“拒绝”，“男性”，“D” ,279 "15","录取","女性","D",131 "16","拒绝","女性","D",244 "17","录取","男性","E ",53 "18","拒绝","男","E",13815","录取","女","D",131 "16","拒绝","女","D",244 "17","录取","男","E",53 "18","拒绝","男","E",13815","录取","女","D",131 "16","拒绝","女","D",244 "17","录取","男","E",53 "18","拒绝","男","E",138
"19","录取","女","E",94
"20","拒绝","女","E",299
"21","录取","男","F", 22
“22”，“拒绝”，“男性”，“F”，351
“23”，“录取”，“女性”，“F”，24
“24”，“拒绝”，“女性”，“F” ,317

如上所示，我看到 csv 文件的输出顺序发生了变化。
问：1和2有什么区别？我们应该按照与 csv 文件相同的顺序在 cassandra 中创建表吗？

我正在使用五节点 Cassandra 集群。最近我删除了键空间并再次创建它。在此之后，我的应用程序无法读取特定的列族并看到墓碑故障阈值，因此，我在整个键空间上运行压缩命令，仍然在日志文件中看到相同的错误，并且页面无法读取文件。任何建议或解决方案

我们的应用程序在具有两个数据中心的六个节点的 Cassandra 集群中运行。

集群信息：

卡桑德拉版本 ：2.0.3

告密者 ：GossipingPropertyFileSnith

分区 器：Murmur3Partitioner

每个 dc 有三个节点。

每个 dc 的复制因子为 2。

每个节点使用 num_vnodes = 256。（都是虚拟节点）

DC1 是一个实时的 dc（本地 dc），它为当前的用户提供数据。DC2 只是一个备份 dc(remote dc)，它不向用户提供任何数据。由于我们计划单独在 DC1 进行维护操作，因此我们将在维护期间制作远程 DC DC2 来为用户服务。

在中断期间，整个 DC1 可能会停机几天。维护完成后，我们将再次让 DC1 为数据提供服务，并让 DC2 用于备份。所以我们需要在停机后在 DC1 中有最新的数据。我们的应用程序将在中断期间处理大量数据（几 GB）。

在关闭 DC1 之前，

1）在 DC1 节点中需要注意哪些事项（如提交日志设置等）

2) 在 DC2 节点中需要注意哪些事项（如提示切换设置等）

停电期间，

3）当整个 DC1 宕机时，提示将写入哪里（在 DC2 的任何节点中？）以及如何处理这些提示？

DC1启动后，

4) 在中断期间，DC1 节点中的复制可能会失败。我们如何使用 DC2 有效地使用最新数据制作/修复 DC1？

我正在尝试cassandra cluster从尚未cassandra安装的节点（即不属于集群的节点（因此不能使用 nodetool））中获取快照。我正在考虑使用 cassandra 驱动程序 3.0.0 来执行此操作。

文档http://datastax.github.io/python-driver/api/index.html没有提到任何 api 来拍摄快照。

那么我应该假设目前不可能达到同样的效果吗？

@Frozen("map<text, text>")在代码字段上添加了带有注释的相应模型类

插入正确但是当我打开 cqlsh 并运行时

select * from data.banks我收到以下错误

另一个问题是当我添加一行值（'1'，{'code2':'435sdfd','code1':'2132sd'}）。它显示插入了一行。但是当我用 ('1',{'code2':'435sdfe','code1':'2132sd'}) 添加另一行时。它抛出 TimedOut 异常。

使用 cassandra 2.1.8 、 cassandra-driver-mapping 2.1.8 、 kundera-cassandra-pelops 3.0 版本。

在我看来，如果重试，使用 IF 会使语句可能失败。因此，该语句不是幂等的。例如，给定下面的 CQL，如果它由于超时或系统问题而失败并且我重试它，那么它可能无法工作，因为另一个人可能在重试之间更新了版本。

Cassandra 中更新的最佳实践是使更新具有幂等性，但 IF 操作员直接反对这一点。我错过了什么吗？

我多次成功使用sstableloader，但出现以下错误：

我不知道这个错误是否与集群节点的 linux 崩溃之一有关？

任何建议将被认真考虑！