Cassandra中的"LOCAL_ONE“读取一致性
Cassandra是一个高度可扩展的分布式数据库系统，"LOCAL_ONE"是Cassandra中的一种读取一致性级别。
读取一致性级别是指在分布式系统中，读取操作返回的数据是否保证一致性。Cassandra提供了多种读取一致性级别，"LOCAL_ONE"是其中之一。
"LOCAL_ONE"级别表示读取操作只需要从本地节点的一个副本中获取数据即可。这意味着读取操作不需要等待所有副本节点返回数据，只要有一个副本节点返回数据即可返回结果。这种级别的读取一致性较低，但具有较低的延迟和较高的可用性。
"LOCAL_ONE"适用于对数据一致性要求不高的场景，例如日志记录、计数器等。由于只需要从本地节点获取数据，所以读取操作的延迟较低，适合对延迟要求较高的应用。
腾讯云提供了与Cassandra相似的分布式数据库产品，例如TDSQL-C和TBase。TDSQL-C是一种高度可扩展的分布式关系型数据库，支持分布式事务和全球部署。TBase是一种高性能的分布式关系型数据库，支持强一致性和高可用性。
了解更多关于TDSQL-C的信息，请访问腾讯云官方网站：TDSQL-C产品介绍
了解更多关于TBase的信息，请访问腾讯云官方网站：TBase产品介绍
相关·内容
1回答
在我的cassandra用例中，写入之后是读取，我们观察到来自cassandra的陈旧读取。我知道在cassandra中很难实现读的一致性，但是什么是可选的，我们如何知道读是过时的？只要我知道读是过时的，写还在跟上，我就应该做得很好，我不能承受的是返回过时的数据。
寻找基于spring boot和spring data cassandra的解决方案
浏览 5提问于2021-10-03得票数 1
面对问题，java中的Cassandra连接器可能返回Cassandra中日期列的错误值。如果我重新加载应用程序，一切都会好起来的。我不知道为什么会发生，我怎么解决
正如您所看到的，它返回对象的地址，但不返回值。
浏览 5提问于2022-07-06得票数 1
我们在一个多dc集群中使用Cassandra2.1.2( DC1上有30台服务器，DC2上有10台)，关键空间复制因子在DC1上为1，在DC2上为2。
由于某种原因，当我们增加DC1上的写请求量(使用一个或LOCAL_ONE)时，DC2节点上的cassandra进程会随机下降。
当DC2节点开始下降时，DC1节点上的负载平均值约为3-5，DC2上的负载平均值约为7-10。所以没什么大不了的。
看一看卡桑德拉的system.log，我们发现了一些例外：
ERROR [SharedPool-Worker-43] 2014-11-15 00:39:48,596 JVMStabilityInspect
浏览 3提问于2014-11-15得票数 0
1回答
我试图使用spark来处理一个大型cassandra表(大约4.02亿个条目和84个列)，但是我得到的结果不一致。最初的要求是将一些列从这个表复制到另一个表中。在复制数据之后，我注意到新表中的一些条目丢失了。为了验证我是否计算了大型源表，但每次都得到不同的值。我在一个较小的表(大约700万条记录)上尝试了查询，结果很好。
一开始，我尝试使用pyspark进行计数。这是我的火种脚本：
spark = SparkSession.builder.appName("Datacopy App").getOrCreate()
df = spark.read.format("org
浏览 0提问于2018-03-03得票数 3
回答已采纳
我们已经在亚马逊网络服务中实现了一个四节点的Cassandra集群，现在希望将相同的数据迁移到Azure.currently当我们尝试进行Cassandra复制时，我们观察到它处于活动活动模式，负载在主站点和辅助站点的所有服务器之间进行拆分这会导致在主站点上进行的查询结果中的数据不一致，因为它以某种方式平衡了负载并从辅助站点渲染数据我们希望您的帮助知道这是否可以限制，或者在Cassandra中是否可以进行故障切换同步。任何建议都将不胜感激。谢谢
浏览 2提问于2016-10-13得票数 0
我正在创建一个同步程序，定期将Cassandra数据复制到另一个数据库中。我要复制的数据库只获取插入-数据从来不是UPDATEd或DELETEd。我想从两方面谈谈卡桑德拉的最终一致性模型：
每次同步扫描与最后一次同步扫描重叠一定的时间跨度。例如，如果扫描每小时进行一次，那么每次扫描都向后看一个半小时。数据包含一个唯一的键，因此在多个扫描中读取相同的记录不是问题。
2-我使用一个一致性级别的所有，以确保我扫描集群上的所有节点的数据。
在这种情况下，所有的一致性都是最好的吗？我只需要在任何节点上看到一个记录，我不在乎它是否出现在任何其他节点上。但我也不想错过任何INSERTed记录。但我也不想经历
浏览 1提问于2021-03-18得票数 1
回答已采纳
2回答
在使用asp.net csharp查询cassandra列家族时，我得到了以下错误。我的卡桑德拉版本是1.2.1
Cassandra.ProtocolErrorException类型的未处理异常发生在Cassandra.dll中
附加信息:用于一致性级别的未知代码10
请提出决议。
浏览 4提问于2016-03-01得票数 3
回答已采纳
1回答
在很少有人成功地把数据吞进卡桑德拉和斯帕克之后，
每当我尝试使用Spark (几分钟或立即)摄取数据时，都会返回一个错误：
Caused by: com.datastax.oss.driver.api.core.AllNodesFailedException: Could not reach any contact point, make sure you've provided valid addresses
我使用简单的CQLSH (不是火花)进行了检查，并且确实返回了类似的错误(4个节点中的2个节点)：
Connection error: ('Unable to conn
浏览 1提问于2021-09-21得票数 2
回答已采纳
卡桑德拉版本:apache- cassandra -2.1.8
我最近配置了两个节点集群，将Authenticator设置为PasswordAuthenticator。当其中一个节点关闭时，我无法登录到Cqlsh并获得以下错误
Connection error: ('Unable to connect to any servers',
{'192.168.0.45': AuthenticationFailed(u'Failed to authenticate to 192.168.0.45: code=0100 [Bad credentials]
m
浏览 9提问于2015-07-26得票数 7
回答已采纳
1回答
我使用dsbulk 1.6.0从cassandra 3.11.3卸载数据。
每次卸载都会导致行数大不相同。以下是三个卸载调用的结果，它们位于同一个集群上，连接到同一个cassandra主机。正在卸载的表只会追加，数据永远不会被删除，因此不应该出现卸载行的减少。集群中有3个cassandra数据库，复制因子为3，因此所有数据都应该显示在所选主机上。此外，这些都是快速执行的，增加的行数将是数百行(如果有的话)，而不是数万行。
运行1：
│总计\x{e76f}
│10,937 -7/ 97 -97- 15,935.46 - 20,937.97 - 20,937.97
│操作卸载20201024-0
浏览 2提问于2020-10-26得票数 1
回答已采纳
我遇到了非常奇怪的行为，并试图了解在什么情况下可能发生这种情况。在我的Python应用程序中，我通过访问Cassandra数据库。
如下所示，首先，我执行一个INSERT操作，它在表中创建一个记录。接下来，我执行一个SELECT操作，该操作应该返回前面创建的最后一条消息。有时select操作会将空值返回给我。我假设Cassandra有一个内部调度程序，可以让INSERT任务工作。但是，当我试图通过SELECT操作获取最后一个记录时，还没有创建记录。这个是可能的吗？
问题
在成功创建记录的插入操作之后，是否有可能从Cassandra获得回调？
片段
import uuid
import sys
浏览 3提问于2020-11-25得票数 1
回答已采纳
在我的代码中，我将一个现有的Cassandra表中的数据读取到一个火花DataFrame中，并将其转换为构建一组具有原始数据反向映射的新表(最终目标是为通过REST提供的搜索查询提供服务)。
最近，我添加了一些追踪，发现了一件我无法解释的事情。下面是一段Scala代码来说明这个问题。
// df: org.apache.spark.sql.DataFrame
//
// control point 1: before writing the data to Cassandra
val inputCount = df.count
// write data to new C* table
df.
浏览 1提问于2018-01-17得票数 2
回答已采纳
Cassandra 3.1 NodeJS驱动程序: cassandra-driver 3.0.0
使用以下语句创建密钥空间：
使用REPLICATION ={ 'class‘：'SimpleStrategy'，'replication_factor’：2 }；
尽管复制因子为2，但出于开发目的，我仅运行一个实例，并将一致性级别设置为1。这就是当我尝试插入带有IF NOT EXISTS子句的任何记录时的问题，我得到了一致性级别错误。但是不带IF NOT EXISTS的语句可以很好地工作。下面是cqlsh的日志：
cqlsh:xxxxxx> CONSISTEN
浏览 10提问于2016-01-02得票数 4
在有些情况下，操作符会在Cassandra日志中看到以下警告：
WARN ... Replica filtering protection has cached over 2000 rows during query \
[SELECT ... FROM ... WHERE ...]. (See 'cached_replica_rows_warn_threshold' in cassandra.yaml.)
或者在最坏的情况下，一个错误：
ERROR ... Replica filtering protection has cached over 32000 rows du
浏览 0提问于2022-08-16得票数 1
回答已采纳
1回答
谁能解释一下火花的内部工作时，从一个表读取数据，并将它写入另一个卡桑德拉。
这里是我的用例：
我正在摄取从IOT平台进入卡桑德拉通过卡夫卡主题的数据。我有一个小python脚本，它解析kafka的每条消息以获得它所属的表名，准备一个查询并使用datastax的cassandra驱动程序将其写到cassandra。有了这个脚本，我就能在300000记录下，每分钟吃一次，进入卡桑德拉。然而，我的输入数据率是每分钟510000记录，所以卡夫卡的消费滞后持续增加。
Python脚本已经在对cassandra进行并发调用。如果我增加python执行器的数量，cassandra驱动程序就会开始失败，因为c
浏览 1提问于2018-06-01得票数 1
我有一个cassandra集群，它的读取延迟在写过程中增加。写作大多是通过夜间的火花作业进行的。写入过程中会发生巨大的突发事件，是否有一种方法可以减少写入过程中的读取延迟。写入使用LOCAL_QUORUM进行，读取使用LOCAL_ONE进行。当发生写操作时，是否有减少读取延迟的方法？
卡桑德拉星系团
10个节点卡桑德拉集群( DC1中5个，DC2中5个)
CPU: 8核心
内存:32
Grafana度量
浏览 4提问于2021-01-06得票数 0
回答已采纳
我在AWS的Kubernetes集群上成功创建了Cassandara Petset。然而，这是一个单一的DC Cassandra集群。考虑为cassandra添加多DC支持。比如说，在美国西部有一个kubernetes集群，一个在美国东部，一个在欧洲。我希望在每个DC上都安装cassandra，并且能够在这3个集群之间复制数据。我没有答案的问题是如何让美国西部的cassandra petset节点知道欧洲的另一个cassandra petset节点？在DNS连接之前，它们不能解析彼此的DNS名称，对吧？有没有人有经验？
浏览 1提问于2016-10-08得票数 1
我对卡桑德拉选择的策略有一个简单的问题，当发生以下情况时
场景
在T1，replica 1像name = amit, language = english一样接收写突变。
在T1 + 1中，副本2像language = japanese where name = amit一样接收更新
假设，如果在对记录进行更新时没有在副本2上复制写记录，那么Cassandra是如何处理该场景的。
我猜想-可能是副本2将检查update消息的lamport时间戳，将其称为102，并向副本1请求任何小于102的记录，以便它(复制2)可以先执行它们，然后执行update语句。
任何帮助都将
浏览 4提问于2022-07-23得票数 1
2回答
我正在用NetworkTopologyStrategy和PropertyFileSnitch在4个DC上测试Cassandra2.0的部署。每个DC的复制配额为1，这意味着每个DC都有完整的数据库。我的密钥空间被配置为一致性"one“读取。这意味着(正如我所理解的)客户端可以在本地获取数据，如果数据可用，而不执行任何quorum等。
不幸的是，我的测试结果表明并非如此。如果我人为地(使用MiniNet)增加其中一个DC的延迟时间，我可以看到我对其他DC的读取速度明显减慢(按比例计算，延迟比dynamic_snitch_badness_threshold慢)。
在这个测试中，我没有写任何
浏览 3提问于2014-01-28得票数 3
回答已采纳
我们有2个数据中心，每个数据中心都有3个节点，每个数据中心(总共6个副本)的复制系数为3，读取一致性级别为LOCAL_ONE。由于我们没有使用LOCAL_QUORUM或DC_LOCAL_QUORUM，那么在每个数据中心使用3个节点可以接受吗？
为了跨数据中心获取最新信息，是否有人可以为读取操作与当前配置的最佳一致性级别提供建议？
Configuration:
Solr DC1 : 3 nodes, RF=3
Solr DC2 : 3 nodes, RF=3
Versions:
dse 4.8.3
cassandra 2.1.11
谢谢
浏览 1提问于2016-01-29得票数 0
你的招式很好，
我们在Cassandra日志中看到了一些错误，比如：
ERROR [ReadRepairStage:24984] 2022-10-18 10:05:32,622 CassandraDaemon.java:228 - Exception in thread Thread[ReadRepairStage:24984,5,main]
但是，我们已经禁用了读取修复程序。
圣母院环境：
卡桑德拉: 3.11.5
集群复制: RF 3，DC1 : 1，DC2 : 1，DC3 :1
读取所有表的修复设置: dclocal_read_repair_chance = 0.0和read
浏览 9提问于2022-10-19得票数 0
作为POC的一部分。我有一个带有system_auth键空间RF=1的1节点cassandra集群。
我向这个集群添加了第二个节点(带有空数据/提交日志/saved_cache目录)，我注意到用户凭据被复制到新节点。由于RF=1用于现有节点，所以我不希望它复制到新节点。
有什么原因吗？
Cassandra版本: 2.1.8
浏览 3提问于2017-01-30得票数 1
回答已采纳
我们已经在Cassandra中设置了多数据中心复制，并确定需要将一致性级别配置为Each_Quorum (参见)。但我无法确定我到底需要在哪里配置这个一致性级别，请帮助。
提前谢谢。
浏览 5提问于2016-10-15得票数 1
我有一个具有密钥空间的3节点Cassandra集群，其复制因子为3：
CREATE KEYSPACE demo
WITH REPLICATION = {
'class':'SimpleStrategy',
'replication_factor':3
};
(仅部署在一个数据中心)
在进行失败测试时(即删除一个节点)，当尝试对我的密钥空间进行查询时，我会得到这些异常：
Caused by: org.apache.cassandra.exceptions.UnavailableException: Cannot achie
浏览 0提问于2018-03-06得票数 8
我们使用一个多数据中心(DC) cassandra集群。在写入集群期间，我只希望本地DC对其节点执行写操作，因为我们已经将写入请求路由到所需的DC，只基于启动写入的源。因此，我只希望本地DC处理写入，而不希望其他DC对其节点执行写入操作。但后来，由于在各DC节点之间进行复制，我希望在DC之间复制书面数据。当我在第一个place.If中限制只写入一个DC时，在写入操作期间不打开与位于不同DC中的远程主机的连接时，是否有可能在DC之间复制数据。我之所以绝对需要在所有DC中复制数据，是因为在从集群读取数据时，我们希望从读取请求的任何DC读取数据，而不一定是本地请求。
有谁能解决这个问题吗？
浏览 0提问于2018-07-20得票数 3
回答已采纳
1回答
作为对这个问题的跟进：
我想了解，我得到了Request timed Out错误，如果我在服务器日志中看到，我只得到以下错误。
ERROR [SharedPool-Worker-34] 2018-06-01 10:40:36,589 ErrorMessage.java:338 - Unexpected exception during request
java.lang.RuntimeException: org.apache.cassandra.exceptions.ReadTimeoutException: Operation timed out - received only 0 res
浏览 4提问于2018-06-02得票数 2
1回答
指望RDD给出不同的结果
、、、
我有一个RDD，它的行数超过7500万行，当我在上面调用count函数时，每次都会得到一个不同的数字。我的理解是伯爵应该给出确切的数字。
编辑
为了给出数据的概念，结构是这样的
Userid: 1
Date: 8/15/2015
Location: Building 1
...
Date 8/1/2015
Location: Building 5
...
Userid: 2
Date: 7/30/2015
Location: Building 10
...
Date: 6/1/2015
Location: Building 3
...
分区键：Us
浏览 0提问于2015-08-18得票数 3
回答已采纳
1回答
我有一个要求扫描一个表，其中包含1亿记录在生产。搜索将在第一个聚类键上进行。需求是找到唯一的分区键，其中第一个聚类键匹配一个条件。这张桌子看起来像-
员工，公司名称，lastdateloggedin，地板，滑动时间戳
分区密钥-员工聚集密钥-公司名称，lastdateloggedin
我想得到select distinct(employeeid)、company、swipetimestamp，其中公司名称= 'XYZ‘。这是我想从表中获取的SQL表示。
SparkConf conf = new SparkConf().set("spark.cassandra.connecti
浏览 5提问于2020-06-12得票数 0
1回答
我的应用程序在生产环境中每秒运行100多个事务。我想知道应该使用配置来实现这一点。
在非生产环境中，我使用DCAwareLoadBalancingPolocy和一致性级别为LOCAL_QUORUM的群集。
所有剩余的配置都保留为默认配置。
默认配置是否足够，或者我需要指定所有连接选项，如池化选项、套接字选项、一致性级别等
PS: Cassandra版本3请建议如何扩展它。
浏览 6提问于2018-08-15得票数 0
回答已采纳
我正在尝试使用官方的python驱动程序运行cqlsh查询：
>>> session.execute('select count(*) from cassandra_table')
我得到了以下错误：
ReadTimeout: Error from server: code=1200 [Coordinator node timed out waiting for replica nodes' responses] message="Operation timed out - received only 0 responses." inf
浏览 14提问于2018-01-05得票数 0
回答已采纳
我的项目需求是这样的。我们使用多数据中心(DC) cassandra集群。在写入到群集期间，我只希望本地DC在其节点上执行写入，因为我们已经将写入请求路由到所需的DC，仅基于发起写入的源。因此，我只希望本地DC处理写操作，而不希望其他DC在其节点上执行写操作。但是稍后，通过跨DC的节点之间的复制，我希望跨DC复制写入的数据。当我首先将写入限制为只有一个DC时，是否可以跨DC进行这种复制？为此，我考虑使用DCAwareRoundRobin策略。如果我在写操作期间没有打开到位于不同do中的远程主机的连接，以后是否可以在do之间复制数据。为什么我一定需要所有DC中的数据副本，因为在从群集读取数据的过
浏览 0提问于2017-09-05得票数 1
上下文：
我们有一个Cassandra集群，其中3个节点部署为Openshift中的一个状态集。这三个节点配置在相同的数据中心、相同的机架中。
我还编写了一个脚本来测试Cassandra一致性级别的错误。它作为Openshift中的一个荚运行，连接到集群，并在循环中运行select查询。它知道所有Cassandra节点的IP地址。
问题：
如果我将有状态集中的副本数量从3减少到2(也在该节点上运行nodetool drain )，脚本将无法再连接到集群。我得到以下错误：
cassandra.cluster.NoHostAvailable：(“无法连接到任何服务器”，{‘172.17.0.10’
浏览 0提问于2019-02-01得票数 1
回答已采纳
1回答
我在使用python将大列表插入到Cassandra时遇到了问题。我有一个包含3200个字符串的列表，希望保存在Cassandra中：
CREATE TABLE IF NOT EXISTS my_test (
id bigint PRIMARY KEY,
list_strings list<text>
);
当我减少我的列表时，我没有问题。它起作用了。
prepared_statement = session.prepare("INSERT INTO my_test (id, list_
浏览 13提问于2017-03-13得票数 0
回答已采纳
单个集群2节点数据中心，用于复制测试，将一个节点删除，然后在其他节点运行select查询时出错。
此外，一致性级别为1，复制因子为2。
com.google.common.util.concurrent.UncheckedExecutionException: com.google.common.util.concurrent.UncheckedExecutionException:选择*从test_telecom.network4G；ServerError: ServerError java.lang.RuntimeException: org.apache.cassandra.excep
浏览 0提问于2019-08-20得票数 1
1回答
Cassandra写入超时写入
、、、、
我正在尝试将数据插入到Cassandra中。我有一个1M4整数的列表，我希望将其插入到具有以下模式的表中：
CREATE TABLE IF NOT EXISTS my_table (
node_id bigint,
screen_name text,
centrality float,
friend_follower_id bigint,
is_friend boolean,
is_follower boolean,
PRIMARY KEY ((node_id), friend_follower_id));
为了插入数据，我
浏览 11提问于2017-03-09得票数 2
回答已采纳
我目前正在管理一个由5个节点组成的percona xtradb集群，每天都会插入上百万个节点。写入性能非常好，但读取速度不是很快，特别是当我请求大数据集的时候。
插入的记录是传感器时间序列。
我想尝试apache cassandra来代替percona集群，但我不明白数据读取是如何工作的。我正在寻找的东西，能够拆分查询围绕所有节点，并从一个以上的节点并行读取。
我知道cassandra分片可以有分片副本。如果我有5个节点，并将副本因子设置为5，读取速度是否会提高5倍？
浏览 0提问于2018-10-09得票数 0
1回答
什么将是使用通过分区键查询cassandra的理想方法。我使用where传递键，但这会导致卡桑德拉在引擎盖下添加ALLAOW FILTERING，这反过来会导致超时。
当前设置：
csc.cassandraTable[DATA]("schema", "table").where("id =?", "xyz").map( x=> print(x))
在这里，id是分区(不是主)键，我有一个复合主键，并且只使用分区键进行查询
更新:是的，我得到了一个例外：
一致性LOCAL_ONE读取查询期间卡桑德拉失败(需要1次响应，
浏览 1提问于2016-02-23得票数 1
我在一个6节点的Cassandra集群上运行YCSB，具有默认设置。假设客户已经与协调器建立了连接，并找到了足够的副本以满足其一致性级别，那么如果：
(1)协调员倒职了？YCSB客户会联系不同的协调者吗？
(2)有些复制品被击落了？它会重试还是简单地失败请求？
浏览 5提问于2016-12-15得票数 2
回答已采纳
我正在运行spark-cassandra-connector，遇到了一个奇怪的问题:我将spark-shell运行为：
bin/spark-shell --packages datastax:spark-cassandra-connector:2.0.0-M2-s_2.1
然后我运行以下命令：
import com.datastax.spark.connector._
val rdd = sc.cassandraTable("test_spark", "test")
println(rdd.first)
# CassandraRow{id: 2, name: j
浏览 4提问于2017-02-25得票数 2
我正在编写一个连接到Microsoft Azure CosmosDB中的Cassandra数据库的Java应用程序。根据上的文档页面，cosmosdb有一个选项来设置读取操作的一致性级别。但是，在使用SQL API for cassandra时，我找不到如何做到这一点的示例。我在上扩展了微软提供的示例。该示例使用datastax驱动程序cassandra。
是否可以使用此驱动程序设置一致性级别？
浏览 4提问于2019-06-17得票数 0
我使用3个节点Cassandra2.1.14并使用身份验证器: PasswordAuthenticator。
但是当尝试以cassandra/cassandra的身份登录来创建用户时。有什么事我需要修理一下吗？
cassandra@cqlsh>用密码“测试”超级用户创建用户测试；
ServerError：
org.apache.cassandra.exceptions.UnavailableException:无法实现一致性级别LOCAL_ONE">
系统日志显示：
ERROR SharedPool-Worker-1 2016-06-27 07:17:36
浏览 2提问于2016-06-27得票数 2
如链接中所述，读取一致性级别'LOCAL_ONE‘表示返回来自本地数据中心中最近的复制副本的响应。但是，我不明白哪一个是本地数据中心？它是协调器节点所属的节点吗？
浏览 61提问于2018-01-08得票数 2
1回答
我正在尝试使用Datastax中的连接器(v2.0.2，Sparkv2.0.0)：
val df = sparkSession.sparkContext.cassandraTable[MyRec](keyspace, tableName).toDF()
df.write.format("orc").save(hdfsLocation)
它看上去非常简单，并在一段时间内运行良好，但我开始得到这样的例外：
Caused by: com.datastax.driver.core.exceptions.ReadFailureException:
Cassandra failure
浏览 3提问于2017-09-04得票数 0
回答已采纳
我有130.000个数据行，在cassandra上有许多读、写和删除操作。
有时会出现这个错误消息，这意味着我的系统中肯定有一些错误，但我不知道哪里有问题，哪里有问题：
code=1100 [Coordinator node timed out waiting for replica nodes'
responses] message="Operation timed out - received only 0 responses."
info={'received_responses': 0, 'required_responses'
浏览 1提问于2016-05-12得票数 2
我希望您能帮我，我正在用spring引导和keyspace (cassandra aws)编写crud，spring的一致性级别是默认的，而且我无法编写数据，因为我得到了以下错误：
"message": "Query; CQL [INSERT INTO tabledemoach (address,ciiu,creation_date,email,id,name,phone,state,user_activation_status) VALUES (?,?,?,?,?,?,?,?,?)]; Consistency level LOCAL_ONE is not suppor
浏览 7提问于2022-07-14得票数 2
2回答
我们的Cassandra集群在亚马逊EC2上运行，环中有4个节点。我们面临着数据不一致的问题。我们在使用"cqlsh“shell时更改了一致性级别2，解决了数据不一致的问题。
但是我们不知道“如何在Cassandra集群上设置一致性级别？”
浏览 0提问于2016-10-14得票数 0
这个查询很好，但是如果我更改获取数据的时间，我会得到下面的错误(超过200,000行)。我不确定问题是查询还是填充/重采样操作。我在集群中只有一台机器。
rsltES = session.execute( """SELECT * FROM tickdata.timeseries
WHERE
curve = 0
AND symbol = 1000
AND time > '2016-05-23T08:00:00-0400'
AND time < '2016-05-25T19:00:00-04
浏览 0提问于2016-05-25得票数 1
在org.springframework.data:spring-cql中，
package org.springframework.cassandra.core;
/**
* Generic Consistency Levels associated with Cassandra.
*
* @author David Webb
*/
public enum ConsistencyLevel {
ANY, ONE, TWO, THREE, QUOROM, LOCAL_QUOROM, EACH_QUOROM, ALL, LOCAL_ONE, SERIAL, LOCAL_SE
浏览 2提问于2016-06-14得票数 0
回答已采纳
我有一个三节点的cassandra 3.11.4集群，复制因子为3，键空间的大小小于7G，我想运行允许过滤的查询，但得到了ReadTimeout异常，我设置一致性级别为local_one，并在所有三个节点中将read_request_timeout_in_ms的值增加到20秒，然后重新启动节点，但我得到的ReadTimeout错误早于20秒，几乎在10秒后，我也使用cqlsh --request-timeout120在cqlsh中设置了超时，但它也不起作用，有人能帮我吗？
浏览 0提问于2021-07-03得票数 0
在使用cqlsh查询dse 6.7时，我遇到了一个问题。 Invalid Request: Error from server: code=2200 [Invalid query] message="Unsupported consistency level: LOCAL_QUORUM. Supported consistency levels for Search are: ONE, LOCAL_ONE". 我的问题很简单： 查询： select * from esc shipment . shipment search where shipper id like '
浏览 34提问于2020-10-07得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
