在<CassandraResult>.all()中使用Cassandra时，会擦除正在使用的数据吗？
在使用Cassandra时，在<CassandraResult>.all()方法中不会擦除正在使用的数据。该方法用于获取Cassandra数据库中的所有数据，并返回一个结果集。它会返回一个包含所有数据的列表，而不会对原始数据进行修改或删除。
Cassandra是一个高度可扩展的分布式数据库系统，具有分布式、高可用性和容错性的特点。它采用了分布式的架构，数据会被分布在多个节点上，每个节点都可以独立地处理查询请求。在使用Cassandra时，数据是以键值对的形式存储的，每个键对应一个值。
<CassandraResult>.all()方法是用于检索所有数据的一种常用方式。它会返回一个包含所有数据的列表，可以通过遍历这个列表来访问每一条数据。在这个过程中，不会对原始数据进行任何修改或删除操作。
对于使用Cassandra的应用场景，它适用于需要处理大量数据和需要高度可扩展性的场景。例如，社交媒体平台、物联网应用、日志分析等都是Cassandra的典型应用场景。
腾讯云提供了一系列与Cassandra相关的产品和服务，例如TencentDB for Cassandra。TencentDB for Cassandra是腾讯云提供的一种托管式Cassandra数据库服务，它提供了高可用性、高性能和自动扩展的特性，可以帮助用户快速搭建和管理Cassandra数据库。您可以通过访问以下链接了解更多关于TencentDB for Cassandra的信息：
https://cloud.tencent.com/product/tcassandra
相关·内容
我所做的是对sstableloader的合法使用吗？
我正在将一个表从一个Cassandra集群S迁移到另一个集群T。我还有一台安装了Cassandra的机器(L)，用于运行sstableloader。所有Cassandra都来自Datastax Enterprise v4.0.3-1。已经使用cqlsh手动检查了源和目标上的表的模式，并进行了精确匹配。
源机器(S)上的数据和索引sstables是使用nodetool快照命令准备的，并使用sstableloader (L)复制到机器上。来自其中一个目标节点(集群T)的cassandra.yaml文件被复制到带有sstableloader (L
浏览 1提问于2014-07-18得票数 0
我们在同一个机架上有三个节点组成的Cassandra簇。现在，作为服务器上常规维护活动的一部分，我希望每次在一个节点上停止并启动Cassandra的一个实例。
我们使用的复制因子为3，一致性因子为1。
服务器将关闭超过4个小时。所以，当我准备好节点并启动相应的Cassandra实例时，我是否需要手动运行修复，或者Cassandra将自己负责复制在这4个小时内更新、创建和删除的数据。如果我们必须手动在Cassandra上运行修复程序，我可以在已停止的Cassandra实例上运行它吗?否则它将开始接受流量并将旧信息返回给客户端。
如果我必须手动运行修复，请建议步骤，以便当实例启动时，它已经达到数据
浏览 0提问于2021-09-02得票数 2
我的一个节点上的Cassandra服务宕机了，我们无法重新启动它，因为其中一个表中有一些损坏。因此，我们尝试通过删除所有数据文件来重建它，然后启动服务，一旦它出现在环中，我们多次运行nodetool修复，但它被挂起，抛出相同的错误
原因:检测到org.apache.cassandra.io.compress.CorruptBlockException：(/var/lib/cassandra/data/profile/AttributeKey/profile-AttributeKey-ib-1848-Data.db)：损坏，区块长度为1177104，长度为11576。
这发生在恢复6 6gb的数
浏览 1提问于2013-08-03得票数 0
我正在使用spark cassandra连接器(Python)向cassandra写入3000000行8列的数据，当我读回时，我只得到了50000行。当我检查cqlsh中的行数时，也有50000中的行数，我的数据去哪里了，spark -cassandra连接器有问题吗？ 这是我的spark配置 spark = SparkSession.builder.appName("das_archive").config(
"spark.driver.memory", "25g").config('spark.cassandra.connectio
浏览 10提问于2020-06-21得票数 1
回答已采纳
问题
当我有一个大的数据负载时，简单的CQL选择失败。
设置
我使用以下Cassandra模式：
CREATE KEYSPACE fv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor' : 1 };
create table entity_by_identifier (
identifier text,
state entity_state,
PRIMARY KEY(identifier)
);
CREATE TYPE enti
浏览 4提问于2016-10-06得票数 2
回答已采纳
我在EC2上有一个带有2个节点的opCenter (3.0.1)的Datastax集群cassandra (1.2)。我遵循了这个指南：
使用以下命令：
--集群名cass1 --totalnodes 2--使用自己的安全组和正确打开的端口的版本社区(如指南所述)
之后，我可以打开opsCenter并修复2个节点，一切都很正常
然后我想向集群中添加一个新节点(有两种方法)
1-通过opsCenter："Install Errored: the installed agent i responding“(安装错误:已安装的代理似乎没有响应)
实例正在运行，但...
2-通过指南：
我使用
浏览 0提问于2013-03-03得票数 1
我想在每次写操作后做一些与cassandra使用的磁盘空间相关的测试。在我的测试中，我正在推送大量的数据。我在cassandra中创建了一个键空间和一个表。我想知道cassandra使用的磁盘空间来存储我推送到表中的数据。
我注意到，当我插入一些数据时，它不会立即反映到cassandra安装目录中的data目录中。所以我试图阻止cassandra并重启它。因此，我可以看到在keyspace/data文件夹中创建了一些文件/目录。
但我推送到cassandra的数据量应该是MBs，因为它是巨大的。但数据目录的大小以kB为单位，而提交日志的大小为32,768 kB。因此，我不确定是否在重启cass
浏览 0提问于2020-10-26得票数 1
1回答
预先警告-卡桑德拉初学者
我已经使用在aws上设置了一个4节点m3.xlarge集群，并使用Cassandra块加载器方法加载了数据。
卡桑德拉版本是"ReleaseVersion: 2.1.9.791“
这四个节点中的一个--我从其中启动的那个--似乎被压紧了(在过去的12个小时里，没有什么改变)。
$ nodetool compactionstats
pending tasks: 1
compaction type keyspace table completed total unit progress
浏览 6提问于2015-10-30得票数 1
回答已采纳
1回答
我计划使用Java对象作为自定义类型，并存储它Cassandra。我从类中取出两个数据成员，并将它们变成主键，并将其余的数据成员保留在自定义类型中。与按Cassandra数据类型存储单个数据成员相比，data members of my class: name, date_of_birth, occupation, last_visit, family_members, total_income primary key: name, date_of_birth cassandra custom type members: occupation, last_visit, family_membe
浏览 1提问于2015-04-15得票数 5
回答已采纳
2回答
我们在EC2上的cassandra中使用了多个数据目录。其中一个数据目录卷变得100%已满，而另一个卷则为30%空。之后，许多写入失败，最终cassandra停止。我调试并意识到我的设置为stop。后来我将其更改为best_effort，并尝试启动cassandra。如前所述， best_effort如果cassandra不能写入磁盘，那么该磁盘将被列入写入黑名单。因此，理想情况下，100%已满的卷应该已被列入写入黑名单。但是当我启动cassandra时，我发现没有剩余的磁盘空间了，它也没有启动。那么，当我们有多个数据目录并且其中一个变满时，我们应该怎么做呢？我期待更好的答案，而不仅仅是增加完
浏览 2提问于2019-08-27得票数 0
我无法访问部署在kubernetes中相同名称空间上的Cassandra数据库。
我的服务没有集群IP，只有内部端点cassandra.hosting:9042，但是每当我尝试使用
spring.data.cassandra.contact-points=cassandra.hosting
它在错误All host(s) tried for query failed中失败。
浏览 0提问于2018-09-29得票数 4
回答已采纳
2回答
我是Cassandra的新手--我一直在搜索与单个节点上的Cassandra的提交和崩溃恢复相关的信息。还有，希望有人能澄清一下细节。
我正在测试Cassandra -所以，在单个节点上设置它。我在datastax上使用stresstool来插入数百万行。如果出现电气故障或系统关机，会发生什么情况？当Cassandra重启时，Cassandra内存中的所有数据都会被写到磁盘上吗(我猜提交日志起到了中介作用)？这个过程需要多长时间？
谢谢!
浏览 0提问于2013-05-15得票数 5
回答已采纳
我正在运行3个节点apache集群作为码头容器，保存带有45天TTL的timeseries数据。
我计划升级目前的cassandra版本2.2.5到cassandra 3.11.4版本。为升级确定了以下步骤-
备份现有数据
刷新一个cassandra节点
-h cassandra1 -u ca_itoa -pw ca_itoa排水系统
停止cassandra1节点
启动新的cassandra 3.11.4容器
升级SSTable
-u ca_itoa -pw ca_itoa可升级工具
检查节点状态。对其余节点重复此过程。
我对升级过程没什么疑问-
这些步骤正
浏览 1提问于2019-03-22得票数 3
回答已采纳
Apache节点正在3节点集群中运行，复制因子为3。所有配置都是正确的。卡桑德拉版本为2.1.8。
让我们假设数据在逻辑上损坏到无法修复的程度，这意味着它不能被常用的工具(刷洗/修复)所恢复。
节点处于正常状态。
考虑通过从已在cassandra.yaml中注册的种子节点(而不是用另一个节点替换该节点)进行节点恢复的场景：
如果删除该节点上的顶级数据目录(包括提交日志、数据、提示和saved_caches目录)并启动服务，会发生什么情况？从那时起，节点会优雅地恢复吗?我只需运行nodetool修复，将最古老的数据输入到节点中？
如果我启动服务并运行nodetool，重新构建，那么它是否
浏览 2提问于2017-01-03得票数 1
回答已采纳
我正在与JanusGraph和卡桑德拉的后端比赛，但我有一些疑问。
我有一个Cassandra服务器在我的机器上运行(使用Docker)，在我的API中我有以下代码：
GraphTraversalSource g = JanusGraphFactory.build()
.set("storage.backend", "cql")
.set("storage.hostname", "localhost")
.open()
.traversal();
然后，通过我的AP
浏览 3提问于2020-03-10得票数 1
回答已采纳
已通过opscenter开始修复整个群集，其中一个节点出现以下错误。
ERROR [CompactionExecutor:530] 2016-03-04 18:25:39,893 CassandraDaemon.java:227 - Exception in thread Thread[CompactionExecutor:530,1,main]
java.lang.AssertionError: /data/cass_data/data/system/local-7ad54392bcdd35a684174e047860b377/system-local-ka-3046-Data.db
浏览 0提问于2016-03-05得票数 1
当使用像Cassandra这样的nosql类型的数据存储时，如何根据列返回结果集？
例如：
SELECT *
FROM Articles
WHERE category='blah'
ORDER BY datetime DESC
您是否会将其存储在sql数据库中，然后从cassandra中提取数据？或者cassandra可以处理这种类型的查询吗？(假设数据库中有数百万行)
据我所知，cassandra很擅长基于键的查找，不知道它是否可以也应该用来获取数据列表并对数据进行分页(如果它的性能很高)
浏览 1提问于2010-04-02得票数 3
我正在测试Cassandra在同时读写操作的情况下的性能。
READ操作的延迟对我来说很重要，通常每天写一次，所以我正在研究WRITE操作是否会影响READ操作延迟。
我有一个表格的10_000记录，我READ从申请在50个RPS。例如，延迟为10 is，REQUEST_SERIAL_CONSISTENCY和REQUEST_CONSISTENCY为READ操作的QUORUM。
对READs的查询是：SELECT * from table where id = X
同时，我运行另一个应用程序，该应用程序向表中插入相同的记录(具有相同的I，因此实际上是UPDATE操作)，REQUEST_SERIA
浏览 4提问于2022-06-06得票数 0
我有一种情况，我不知道数据是否存在于一组表中。因此，到目前为止，我正在对所有这些表执行DELETE。因此，在Cassandra中，一个API调用会导致大约30-50个删除。最近，大多数删除操作都是在不存在的数据上执行的。Cassandra的性能还会因为数百万次不存在的数据删除而受到负面影响吗？在删除我不确定是否存在的数据时，我应该使用'IF EXISTS‘吗？
浏览 21提问于2017-01-30得票数 3
回答已采纳
我们正在经历集群上的长时间修复(9到14小时)(目前在3个节点*3个数据中心上分离了2Tb的旧数据)。
我们每天都在运行全面的修复(在某个时候，-pr遇到了一些问题，但再也没有恢复)，日志显示，大部分时间都花在压缩大行(我们很快就会处理)和同步范围同步上。
举个例子，我有一个CF，有时超过7K的范围不同步，有时是来自OpsCenter的汇总表，处于相同的情况下(我的CF得到了大量的插入和使用TTL)。另外，nodetool tpstats没有显示丢弃的消息。
我们正在使用Cassandra 1.2.11 (我知道最新版本是1.2.13，但是修复性能方面的缺陷，比如CASSANDRA-4905，
浏览 1提问于2014-01-02得票数 1
回答已采纳
我正在从spark的cassandra表中读取一张表。我在cassandra中有很大的分区，当cassandra的分区大小超过64MB时，在这种情况下，cassandra分区将等于spark分区。由于分区太大，我在spark中遇到了内存问题。
我的问题是，如果我在从cassandra读取数据后开始重新分区，spark分区的数量会发生变化吗？它不会导致火花记忆问题吗？
我的假设是，spark首先会从cassandra读取数据，因此在这个阶段，cassandra的大分区不会因为重新分区而拆分。重新分区将处理从cassandra加载的底层数据。
我只是想知道，当从spark读取数据时，重新分区是否会
浏览 48提问于2021-06-07得票数 1
1回答
我正在为Cassandra使用Datastax，在CFS之上，我正在尝试使用Hive.Cassandra加载数据，在插入和updating.My时，在列级具有TTL (生存时间)。问题是，当我们使用配置单元将数据加载到列Family.Is中时，我们如何才能获得相同的TTL ?有什么方法可以指定ColumnFamily的TTL，或者从Hive加载时？？
示例(参考datastax网站)：使用TTL 86400将cqlsh:demodb>插入用户(user_name，密码)值('cbrown'，'ch@ngem4a')；
使用TTL 432000设置‘cqls
浏览 3提问于2013-11-25得票数 0
我已经在Cassandra中插入了大量数据。现在我想随机查询一条记录。但我不知道primary key。所以我想要一种在Cassandra中获取all data的主键的方法，然后我可以使用一个随机的主键来查询数据。
我可以从Cassandra的data目录中获得它吗？我只在那个目录中找到了.db文件。
浏览 16提问于2017-02-17得票数 3
我正在使用cassandra在我的应用程序上存储数据。一切都很好，直到我试着阻止它。当停止时，有时我会显示NullPointerException，如下所示：
15:58:56.869 ERROR [Thread-2] [CassandraDaemon.java:185] Exception in thread Thread[Thread-2,5,main]
java.lang.NullPointerException: null
at org.apache.cassandra.thrift.ThriftServer.stop(ThriftServer.java:70) [cassandra-
浏览 20提问于2017-01-17得票数 1
回答已采纳
替换死节点和重新启动死节点(特别是种子节点)之间有什么区别吗？实际上，我对如何重新启动死种子节点感到有点困惑。
当种子节点的进程崩溃时，我是否应该重新启动它而不对cassandra.yaml做任何更改？或者，就像替换种子节点一样，我应该从每个节点的种子列表(cassandra.yml)中删除它的IP地址吗？
对此并不清楚。它只讨论如何用另一台机器替换死节点。
谢谢你
浏览 3提问于2015-05-18得票数 1
回答已采纳
我们正在尝试创建一个从cassandra db返回分页结果的应用程序，用于UI。 UI会将fetchSize和pagingState传递给我们的API，并在此基础上返回size=fetchSize的List<MyObject>。如果传递了pagingState，我们将从最后一页继续查询(如cassandra docs：https://docs.datastax.com/en/developer/java-driver/3.6/manual/paging/中所述) 请注意，我使用的是Cassandra驱动程序3.6版。 但是当我们实现这一点时，Cassandra总是返回数据库中的所
浏览 29提问于2019-06-13得票数 2
回答已采纳
我的项目中有一个janusgraph-cassandra依赖项，它带来了cassandra-all传递依赖关系。
现在，我正在尝试将cassandra-all依赖关系从2.1.20升级到3.11.4，但它似乎与父级janusgraph-cassandra 0.3.1不兼容。
是否有方法检查父依赖项和传递依赖项之间的版本兼容性？还是应该将maven工件本身带来的版本兼容作为经验法则？
浏览 2提问于2019-05-31得票数 1
回答已采纳
1回答
我们正在检查将我们的一个应用程序迁移到(AWS)的可行性。我们决定使用AWS API网关公开服务，使用AWS Lambda (java)进行后端数据处理。lambda函数必须从我们的数据库中获取大量数据。目前使用Cassandra作为数据存储，它已经在EC2实例中设置，并且没有公共ip。
有人能建议一种使用私有Ip ( 10.0.x.x)从AWS访问Cassandra(EC2)的方法吗？
在大规模应用程序中使用AWS是正确的选择吗？
浏览 0提问于2018-04-12得票数 0
我从cassandra获取一些数据来激发，当数据足够大且不能一次缓存在内存中时，我必须使用spark.cassandra.input.split.size_in_mb来设置数据的大小--一次机器可以get.But --我也想用更长的时间来缓存数据，代码如下：
val conf = new SparkConf().setAppName("CassandraLogAnalyse")
.set("spark.cassandra.connection.host", "xxx")
.set("spark.cassandra.auth.use
浏览 2提问于2015-11-24得票数 1
回答已采纳
我在cassandra中有一个表，我使用客户端TTL =1个月保存数据(表TTL为0)，该表配置了时间窗口压缩策略。
每天卡桑德拉清理一个月前的过期数据。最近我把客户的TTL改成了15天，我希望cassandra在某个时间点每天打扫两个马厩，并释放空间。但它每天都要清理一个，并保存15天的死亡数据。
我怎么知道？
for f in /data/cassandra/data/keyspace/table-*/*Data.db; do meta=$(sudo sstablemetadata $f); echo -e "Max:" $(date --date=@$(echo "
浏览 1提问于2018-06-18得票数 0
回答已采纳
我在titan(cassandra后端)中添加了数据，使用了java。我在java中使用下面的配置来插入数据。
TitanGraph getTitanGraph()
{
conf2 = new BaseConfiguration();
conf2.setProperty("storage.backend", "cassandra");
conf2.setProperty("storage.directory","/some/directory");
conf2.setProperty("s
浏览 5提问于2015-08-18得票数 0
回答已采纳
在cassandra退役期间，我注意到节点尝试发送提示，这需要很长时间，并且永远不会完成。我检查了提示文件夹，发现了超过9+个月的提示。我不确定为什么这些旧的提示仍然存在于文件夹中，所以我决定删除它们。在我删除它们之后，我注意到system.log中有以下条目 INFO [HintsDispatcher:1070] 2021-07-08 11:32:01,056 HintsDispatchExecutor.java:141 - Transferring all hints to /10.199.190.233: 7935f1b5-4725-4dc2-ad6d-b883d53d907d
E
浏览 28提问于2021-07-09得票数 1
回答已采纳
在使用Cassandra 2.1.17时，我在这个场景中遇到了一个问题：
从生产环境(3节点集群)备份和上载数据到aws s3
本地下载这些数据
使用以下命令将这些数据还原到本地cassandra (单节点)：/$cassandra_path/bin/sstableloader -d $local_ip -cph 3 $sstable_path
对本地数据做一些计算
有时候，我可以在本地cassandra集群中获得很多额外的数据，这在在线集群中是找不到的。
我选择其中一条记录，使用sstable2json解释马厩，我可以在直接从s3下载的文件中找到一个墓碑记录，它的时间
浏览 2提问于2019-02-22得票数 0
从我读到的文章中，他们说墓碑会影响Cassandra的读取性能。我正在阅读如何在Cassandra中更新数据，并且看起来数据是在没有修改或读取当前数据的情况下使用时间戳写入的。 因此，当在压缩完成之前执行读取时，需要进行过滤以获取最新的值，对吗？如果是这样的话，墓碑不是一回事，为什么它们会对性能产生负面影响，而不是对行的更新呢？
浏览 11提问于2020-04-11得票数 0
回答已采纳
我正在运行涉及Cassandra数据库中数据的rspec测试。在测试之间擦除/清理数据库的最佳实践是什么？对于我的mongo数据，我正在使用DatabaseCleaner，并且正在寻找与其等效的Cassandra。我目前正在我的spec_helper.rb中做以下事情，但它非常慢，所以我在寻找一个更好的解决方案。谢谢!
config.before :each do
['column1', 'column2'].each do |name|
begin
$cassandra.drop_column_family(name)
浏览 5提问于2012-10-05得票数 5
1回答
我在5个EC2节点上设置了一个Cassandra集群。节点可以使用私有IP地址进行通信，但是在使用私有内部DNS名称时会出现连接故障。本地主机也失败了。
我试图使用cassandra压力工具，但我得到了Failed to connect over JMX; not collecting these stats，在打开详细日志记录时，我得到了以下堆栈：
java.lang.RuntimeException: java.io.IOException: Failed to retrieve RMIServer stub: javax.naming.ServiceUnavailableExceptio
浏览 0提问于2019-03-21得票数 0
我是ElasticSearch新手，我正在为一个项目评估它。
在ES中，复制可以是同步或异步。如果是异步的，只要文档被写到主分片，客户端就会返回成功。然后将该文档异步推送到其他副本。
当异步编写时，我们如何确保当GET完成时，即使数据尚未传播到所有副本，也会返回数据。因为当我们在ES中执行GET时，查询将被转发到适当分片的一个副本。假设我们是异步编写的，主分片可能有文档，但选择的GET副本可能还没有接收/写入文档。在Cassandra中，我们可以在写入和读取时指定一致性级别(ONE、QUORUM、ALL)。对于ES中的读取，这样的事情是可能的吗？
浏览 1提问于2012-12-29得票数 7
回答已采纳
我在AWS的3个节点上安装了DSE4.5。集群最初成功地出现了。我对cassandra.yaml上的端点告密者做了一些更改，现在集群不再出现了。我改回了原来的cassandra.yaml，但节点仍然无法启动。没有数据，因为我在一个项目的开始。
下面是我的问题--是否有办法重新运行安装程序来重新创建每个节点？否则，我将删除这些实例并重新开始。
浏览 0提问于2014-09-09得票数 0
回答已采纳
我使用docker run -e CASSANDRA_SEEDS=10.x.x.x e ubercadence/server:在外部运行cassandra来运行cassandra。它运行得很成功。
Azure cosmos说，任何运行在Cassandra上的系统都可以使用提供的cosmos cassandra APi来使用Azure cosmos，通过修改客户端连接创建代码，例如: GO app示例代码：
func GetSession(cosmosCassandraContactPoint，cosmosCassandraPort，cosmosCassandraUser，cosmosCassa
浏览 7提问于2020-08-10得票数 0
我有两个节点卡桑德拉集群。我打算将它们分成两个单一节点集群。
关闭两个Cassandra实例
在两个节点中编辑cassandra.yaml，将种子更改为指向自己，并设置endpoint_snitch: SimpleSnitch
在两个节点上启动Cassandra
两个节点上的Nodetool 命令都显示了2个节点，而我预计只有一个节点。
我做错什么了？
浏览 4提问于2017-01-19得票数 0
回答已采纳
2回答
我在服务器1上运行了Cassandra 0.8.0和数据，并在服务器2上全新安装了Cassandra 1.0.3。
是否可以仅将一些文件从服务器1复制到服务器2？或者我必须编写自己的导入/导出代码？
这两个服务器都可以关闭、重新启动等。
浏览 4提问于2011-11-24得票数 1
回答已采纳
我正在尝试为一组UTs介绍cassandra-unit，它与org.gradle.parallel=true一起运行，用于一个spring引导应用程序。
运行所有的测试都不是可靠的，尽管偶尔也能工作。
我想这与描述的问题有关，即当下一个UT启动时，第一个实例仍在徘徊，似乎没有办法强迫它“快速”关闭。
我最初给出的结果不可靠的方法是使用org.gradle.parallel=true。
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration
@TestExecutionListeners(
listeners = Cassa
浏览 1提问于2017-02-02得票数 1
我知道，当我们在Cassandra中写入数据时，分区键由分区程序散列，然后使用该值来确定数据将存储到集群中的哪个节点中。然后Cassandra在节点环中以顺时针方向复制数据。 如果分区程序确定的节点已关闭，那么Cassandra如何找到要查找记录的节点？难道我们不会在这里失去分区的优势吗？
浏览 22提问于2020-04-06得票数 1
回答已采纳
1回答
最近，我在我的产品和演示集群中的system.log文件中都出现了以下错误。每个集群有2个节点，复制因子为2。据我所知，没有做任何更改。我不知道错误背后的原因是什么。它导致INSERT和UPDATE语句失败。
[SharedPool-Worker-27] ERROR org.apache.cassandra.transport.Message - Unexpected exception during request; channel = [id: 0xeb429d31, /14.0.0.1:34495 => /14.0.0.2:9042]
jav
浏览 1提问于2018-11-28得票数 0
回答已采纳
我们需要什么来同步从同一个cassandra数据库中获取数据的两个进程？
图像显示cassandra将需要存储一个“整数”值，该值根据“请求”更改值。
首先，这个值为零，一个新的请求出现，我们调用add(new_val)将新的数字添加到数据库中的现有数据中。让我们保持简单的场景..。
但是，当两个不同的请求同时在cassandra行的同一时间写入时会发生什么呢？如何确保选择正确的值？这是卡桑德拉提供的东西吗？
浏览 1提问于2016-10-10得票数 1
回答已采纳
我正在使用教程，当我尝试启动cassandra时，我会得到相应的警告和错误：
类/Library/Java/JavaVirtualMachines/jdk1.8.0_60.jdk/Contents/Home/bin/java和/Library/Java/JavaVirtualMachines/jdk1.8.0_60.jdk/Contents/Home/jre/lib/libinstrument.dylib.都实现了JavaLaunchHelper。两个中的一个将被使用。哪个是未定的。org/apache/cassandra/db/AbstractNativeCell.compareTo (L
浏览 3提问于2015-11-03得票数 3
1回答
我的用例：
从cassandra表创建数据帧。
通过对列进行过滤并修改该列的值来创建输出数据。
使用TTL集将输出数据写入cassandra，以便在短时间(2s)后删除所有修改的记录。
将输出数据返回给一个调用方，该调用者在一段时间后将其写入文件系统。我只能返回一个数据文件给调用者，我没有进一步的控制。而且，我不能增加TTL。
在执行步骤4时，输出数据为空。这是因为，星火重新评估行动的数据，由于血统，卡桑德拉查询再次完成，这现在不产生任何记录。
为了避免这种情况，我在步骤2之后添加了一个步骤：
2a) outputDataframe.cache()
这确保了在第5步中，
浏览 0提问于2018-10-17得票数 2
回答已采纳
到目前为止一切都很好。我们在一台机器上安装了一台超氧化物歧化酶，现在它已经损坏了SSTables。我们正在试图找到正确的过程，使这个节点在线。我只是想杀死数据和修复节点，因为我们有复制2，但我不能这样做，因为在每个节点上的数据量。
附件是错误。
我试着运行nodetool，但是由于DSE无法启动，所以我获得了正常无法连接到127.0.0.1错误的结果。
我应该编辑配置并从策略停止更改为最佳努力，然后启动/运行命令吗？
谢谢,
错误20:58:34由于启动时文件系统异常，磁盘故障策略“停止”org.apache.cassandra.io.sstable.CorruptSSTableExcept
浏览 6提问于2016-02-11得票数 0
使用datastax驱动程序：'cassandra-driver'
以以下方式连接到我的nodejs应用服务器后端的数据库：
const cassandra = require('cassandra-driver');
const client = new cassandra.Client({ contactPoints: [ '${azure_vm_ip}' ] });
输出日志：
{ [Error: All host(s) tried for query failed. First host tried, azure_vm_ip:9042:
浏览 6提问于2018-01-30得票数 0
在与Cassandra打交道时，我学到的第一件事是，你需要非常小心地对待你的数据模型，因为Cassandra不支持joins，聚合等。所以你根据你的查询来建模你的数据，使用广泛的去正规化等。
但是假设我已经决定在Cassandra之上运行Spark。Spark将允许进行连接和聚合，以及对数据进行不同的计算。
所以我的问题是，当我在Cassandra中对我的数据建模时，考虑到我将在上面运行Spark，我是否需要更改我的模型以使它们适合Spark以提高计算速度，或者我仍然需要在普通的Cassandra中坚持数据建模的最佳实践？
例如，如果我在cassandra中有Table1和Table2，它们持
浏览 0提问于2015-06-26得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
