问题标签 [cassandra-3.0]

全部，

我在 Digital Ocean 中有一个 3 节点集群 cassandra。根据 CQL 中的SHOW VERSION的 cassandra版本如下所示

[cqlsh 5.0.1 | 卡桑德拉 3.0.0 | CQL 规范 3.3.1 | 本机协议 v4]

我能够使用 cqlsh 从另一个节点连接到集群的一个节点并运行命令......但是当我尝试使用 java 驱动程序连接时，我得到以下异常

我使用的 java 驱动程序版本是 2.0.10。maven配置如下

我检查了cassandra.yaml，发现以下设置已经正确设置

已正确配置...所以我完全迷失了...任何帮助表示赞赏

我正在尝试在 datastax 中运行 cassandra 3.0。但是我收到一条错误消息，说 Cassandra 3.0 及更高版本需要 Java 8u40 或更高版本。

我已经安装了 java 并将 jdk1.8.0_65 移动到/usr/local/java并将 JAVA_HOME 设置为/usr/local/java/jdk1.8.0_65.

但我仍然面临以下错误：

Cassandra 3.0 及更高版本需要 Java 8u40 或更高版本。

我在用户表上有一个倒排索引表。该表允许按姓氏查询用户。它被称为“users_by_lastname”。

该表的主键中包含“姓氏”，因此无法更新。

如果用户在主“用户”表中更改了他们的姓氏，我应该删除并重新插入倒排索引表“users_by_last name”吗？

我无法更新 Cassandra 中的主键列......还有其他模式可以更好地处理这个问题吗？

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

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

根据这个问题，Cassandra 的存储格式在 3.0 进行了更新。

如果以前我可以使用 cassandra-cli 来查看 SSTable 是如何构建的，则可以得到如下结果：

在最新版本的 Cassandra 中，内部形式会是什么样子？你能举个例子吗？

我可以使用什么实用程序以上面列出的方式查看 Cassandra 中表的内部表示，但使用新的 SSTable 格式？

我在互联网上发现的只是分区标题如何存储列名，行存储聚类值并且没有重复值。

我怎样才能调查它？

使用 Presto 0.131 查询 Cassandra 3.0.0 集群时，我得到：

尝试查询的所有主机都失败了 [..snip...] InvalidQueryException: unconfigured table schema_keyspaces

我认为这是由于 Cassandra 的系统模式发生了一些变化？如果是这样，是否有解决方法或者我们应该等待 Presto 支持 Cassandra 3.0.0？

2016-11-05 更新：较新版本的 PrestoDB 可以在 Cassandra 3+ 上正常工作。当前使用 0.147，但最新版本是 0.156，它们都可以在新协议下正常工作。感谢您的回复。

我最近发现 Cassandra 3.0.0 和 PrestoDB 不能很好地配合使用。

我有很多数据加载到 Cassandra 3.0 中，我不想重建整个事情。在 Presto 更新之前，有没有一种安全的方法可以暂时降级到 2.x，然后我可以回到 3.0？

我知道降级不受官方支持，但我想知道是否更有经验的 SO Cassandra 用户可以在这里为我指明正确的方向。我认为答案将是“不要尝试”，但谁知道呢，也许有办法。提前致谢。

2016-11-05 更新：使用 PrestoDB 的 0.147 及更新版本，此问题已得到解决。最后，我不需要降级 Cassandra 就可以使用 PrestoDB。感谢您的回复。

我有一个 Java 客户端，可以将（插入）记录批量推送到 Cassandra 集群。批处理中的元素都具有相同的行键，因此它们都将放置在同一个节点中。另外我不需要事务是原子的，所以我一直在使用未记录的批处理。

每批中 INSERT 命令的数量取决于不同的因素，但可以是 5 到 50000 之间的任何值。首先，我只是在一批中放入尽可能多的命令并提交。这扔了com.datastax.driver.core.exceptions.InvalidQueryException: Batch too large。然后我使用了每批 1000 个 INSERT 的上限，然后降至 300 个。我注意到我只是在随机猜测，不知道这个限制的确切来源，这可能会在未来造成麻烦。

我的问题是，这个限制是多少？我可以修改它吗？我怎么知道一个批次可以放置多少个元素？当我的批次“满”时？

在 Windows 命令提示符中通过 cqlsh 对 Cassandra 进行编程时，我不小心短路了 PC 的电源。恢复供电后，我尝试通过 cqlsh 重新运行 Cassandra：

C:\Program Files....\apache-cassandra\bin>cqlsh

并收到以下错误消息；连接错误：（无法连接到任何服务器'{'127.0.0.1'：错误（10061，“尝试连接到[（'127.0.0.1'，9042）]。最后一个错误：无法连接，因为目标机器主动拒绝”）}）。

我在一台装有window 7操作系统的PC上使用Cassandra 3.0版，并通过命令提示符使用cqlsh。此 PC 没有与任何外部集群的任何连接。

从与同一错误消息相关的类似问题中，有评论“主动拒绝它”表示主机在您尝试连接时发送了重置而不是确认。....要么是防火墙阻止了连接，要么是托管服务的进程没有在该端口上侦听。这可能是因为它根本没有运行，或者因为它正在侦听不同的端口。启动托管服务的进程后，请尝试 netstat –anb 以验证它是否正在运行并侦听预期的端口。”</p>

基于上述，我查看了 Windows 防火墙入站和出站规则，找不到任何本地端口 9042。不幸的是，我不知道运行 netstat –anb 的路径。

有人可以提供重新建立与端口 9042 的连接的步骤，如果这可以解决问题，或者如何重新建立访问以再次在命令提示符中运行 cqlsh。

有人可以推荐一个适用于 Spark 1.6、Scala 2.10.5 的 Cassandra 3.x 版本吗？！！！！

以下是我正在寻找以下 jar 文件版本的 jar 版本

Cassandra 核心 Cassandra Spark 连接器

谢谢，赛