Cassandra :在consistency LOCAL_QUORUM上执行简单写入查询时超时
Cassandra是一个高度可扩展的分布式数据库系统，它具有高性能、高可用性和容错性。它采用了分布式的架构，可以在多个节点上存储和处理大量的数据。
对于给定的一致性级别，Cassandra使用一种称为Quorum的机制来保证数据的一致性。在Cassandra中，一致性级别可以通过读取和写入操作的副本数来定义。LOCAL_QUORUM是一种一致性级别，它要求在本地数据中心的大多数副本上执行读取或写入操作。
当在一致性级别为LOCAL_QUORUM下执行简单写入查询时，如果超时发生，可能是由于以下原因：
- 网络延迟：Cassandra是一个分布式系统，节点之间的通信可能受到网络延迟的影响。如果网络延迟较高，写入查询可能需要更长的时间来完成，从而导致超时。
- 节点负载过高：如果节点的负载过高，例如处理大量的写入请求或者存储大量的数据，可能会导致写入查询的响应时间增加，从而导致超时。
- 数据一致性：在Cassandra中，写入操作需要在多个副本上完成，以确保数据的一致性。如果在执行写入操作时，某些副本无法完成写入，可能会导致超时。
为了解决超时问题，可以考虑以下几点：
- 调整一致性级别：可以尝试降低一致性级别，例如使用LOCAL_ONE，以减少写入操作的副本数，从而减少写入查询的响应时间。
- 优化网络连接：确保节点之间的网络连接稳定，并且具有较低的延迟。可以通过优化网络配置、增加带宽或使用更可靠的网络设备来改善网络连接。
- 扩展集群：如果节点负载过高，可以考虑扩展Cassandra集群，增加更多的节点来分担负载，从而提高写入查询的性能。
- 检查硬件资源：确保节点具有足够的硬件资源，例如CPU、内存和存储空间，以支持高性能的写入查询。
腾讯云提供了一系列与Cassandra相关的产品和服务，例如TencentDB for Cassandra，它是腾讯云提供的一种托管式Cassandra数据库服务，具有高可用性、高性能和弹性扩展的特点。您可以通过以下链接了解更多关于TencentDB for Cassandra的信息：https://cloud.tencent.com/product/tcassandra
请注意，以上答案仅供参考，具体的解决方案可能因实际情况而异。在实际应用中，建议根据具体情况进行调整和优化。
相关·内容
Cassandra查询正在为select查询超时：
SELECT x, y FROM <table> WHERE unique_id= <value>
但例外
com.datastax.driver.core.exceptions.ReadTimeoutException: Cassandra timeout during read query at consistency ALL (3 responses were required but only 2 replica responded)
at com.datastax.driver.core.except
浏览 1提问于2018-04-30得票数 4
回答已采纳
我们的设置是6个节点，每个DC 3个，每个DC 3路复制。我们用EACH_QUORUM写作。试着用LOCAL_QUORUM阅读。
偶尔，我们会得到一个错误的读取超时：
com.datastax.driver.core.exceptions.ReadTimeoutException: Cassandra time out during read query at consistency ALL (6 responses were required but only 5 replica responded)
我们发现，这个错误实际上并不意味着它所说的。相反，这意味着读取修复被触发，并未能及时完成。
浏览 0提问于2018-07-23得票数 1
我遇到了非常奇怪的行为，并试图了解在什么情况下可能发生这种情况。在我的Python应用程序中，我通过访问Cassandra数据库。
如下所示，首先，我执行一个INSERT操作，它在表中创建一个记录。接下来，我执行一个SELECT操作，该操作应该返回前面创建的最后一条消息。有时select操作会将空值返回给我。我假设Cassandra有一个内部调度程序，可以让INSERT任务工作。但是，当我试图通过SELECT操作获取最后一个记录时，还没有创建记录。这个是可能的吗？
问题
在成功创建记录的插入操作之后，是否有可能从Cassandra获得回调？
片段
import uuid
import sys
浏览 3提问于2020-11-25得票数 1
回答已采纳
提示鲨鱼可以使用-Dspark.cassandra.input.consistency.level=LOCAL_QUORUM (指)系统属性启动，但我一直收到命令行错误。有人能给出一个例子，说明我如何启动DSE并使用LOCAL_QUORUM读取一致性运行查询吗？
浏览 4提问于2015-01-23得票数 0
回答已采纳
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
回答已采纳
在以下配置中，我们得到了一个错误的"cannot achieve consistency level QUORUM" (详细信息)：两个数据中心，每个节点有6个节点，所有节点都在同一个机架上。当CL设置为“本地仲裁”时，它可以工作。
基本上，只要我们使用要求跨DC一致性的一致性级别，它就不能插入数据。"Nodetool“命令显示所有12个节点都已启动并运行。
有什么不对的？非常感谢您的帮助！谢谢迪米特里
密钥空间
CREATE KEYSPACE test6 WITH replication = {'class': 'NetworkTopology
浏览 2提问于2015-12-08得票数 2
专家们，
我有以下配置3节点集群(Cassandra 2.1)：
- Replication factor of 2
- Consistency level ONE
- Driver consistency level SERIAL
- SimpleStrategy
- GossipingPropertyFileSnitch
使用此配置时，如果删除一个节点，则会得到以下错误：
Not enough replica available for query at consistency SERIAL (2 required but only 1 alive)
数据均匀地分布在所有节点上，
浏览 1提问于2018-08-12得票数 2
回答已采纳
我正在尝试在同一个表中插入两个进程。因此，首先我尝试使用LWT输入分区和集群键值，如果成功，则意味着该进程可以在该时间段内继续该工作，否则另一个进程已经完成了该段时间段。LWT的一致性级别设置为1，串行一致性级别设置为LOCAL_SERIAL。
如果第一次插入成功，则完成工作，并使用一致性级别1完成另一次插入。第一条语句有一条TTL语句，用于执行工作的进程在中间终止的情况下，在TTL为90后，行将为空。
即使我运行单个进程，LWT也会因读取或写入超时异常而失败。
下面是准备好的语句和我得到的异常。任何帮助都是非常感谢的。
com.datastax.driver.core.exceptions.
浏览 11提问于2018-06-09得票数 0
1回答
我们想测量Cassandra的性能，所以我们计划将10800行数据写入一个表，每行有大约1MB的数据。对于写作来说，这似乎没有问题。
当我们试图从cassandra读取所有以上10800行时，它总是抛出异常，如下所示：
Cassandra.ReadTimeoutException: Cassandra timeout during read query at consistency One (0 replica(s) responded over 1 required)
at Cassandra.TaskHelper.WaitToComplete[T](Task`1 task, Int3
浏览 4提问于2014-09-02得票数 1
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 2数据中心对，每个数据中心包含一个节点，每个数据中心位于网络上不同的物理服务器上。如果一个数据中心崩溃，另一个数据中心将继续可供读取和写入。我在第三个服务器上启动了我的java应用程序，它的一切运行正常。它正在对cassandra进行读写。
接下来，我断开了连接，从网络中拔出了第二台数据中心服务器的网线。我希望应用程序能够继续运行，没有任何异常发生在第一个数据中心，但事实并非如此。
应用程序中开始出现以下异常：
me.prettyprint.hector.api.exceptions.HUnavailableException: : May not b
浏览 1提问于2013-08-20得票数 2
我有一个复制因子为1的节点，并在该节点上启动了一个批处理语句查询，cassandra写入了数据，但未能在超时限制内确认。然后，它使用下面的堆栈跟踪给出一个写超时异常。
failed `Exception in thread "main" com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ONE (1 replica were required but only 0 acknowledged the write
浏览 1提问于2016-03-09得票数 0
我使用星星之火-SQL2.4.1，星火-卡桑德拉-连接器_2.11-2.4.1与java8和ApacheCassandra3.0版本。
我有我的星星之火提交或星火集群环境，如下所示，加载20亿条记录。
--executor-cores 3
--executor-memory 9g
--num-executors 5
--driver-cores 2
--driver-memory 4g
使用以下配置
cassandra.concurrent.writes=1500
cassandra.output.batch.size.rows=10
cassandra.output.bat
浏览 0提问于2019-09-10得票数 0
回答已采纳
import org.apache.spark._
import org.apache.spark.SparkContext._
import com.datastax.spark.connector._
import com.datastax.spark.connector.cql.CassandraConnector
val conf = new SparkConf()
.setMaster("local[*]")
.setAppName("XXXX")
.set("spark.ca
浏览 3提问于2020-08-12得票数 2
我在python中使用Cassandra2.0。
我创建了一个专栏家庭如下：
CREATE KEYSPACE IF NOT EXISTS Identification
WITH REPLICATION = { 'class' : 'NetworkTopologyStrategy',
'DC1' : 1 };
USE Identification;
CREATE TABLE IF NOT EXISTS entitylookup (
name varchar,
value varchar,
entity_id uuid,
浏览 4提问于2014-05-30得票数 7
回答已采纳
1回答
Cassandra插入失败
、、、、
我们遇到了在cassandra表中写入数据的问题。
流程如下..我们从XXX中删除具有某个主键的所有记录。然后在循环中插入新的。
execute("DELETE FROM XXX WHERE key = {SOME_UUID}");
for(int i = 0; i < 5; ++i) {
execute("INSERT INTO XXX (key, field1, field2) VALUES ({SOME UUID},'field1','field2')";
}
结果是:有时并不是所有的行都插入到表中。查询表之
浏览 3提问于2014-09-29得票数 1
我在Cassandra中有一个3 DC环，每个DC有一个4节点集群。所以它的4个节点*3(DC)= 12个节点。我正在测试Cassandra在某些节点宕机时的行为，当我们有Quorum一致性级别时。我们将每个数据中心的复制因子设置为3。所以我们的
Quorum = Floor(Sum of Replication FActor/2) + 1. RF = 3 quorum= 5.
从理论上讲，如果我的12节点集群中有5个节点，我应该可以很好地进行读写。因此，我关闭了一个完整的数据中心DC1，以及另一个数据中心(Dc2)中的3个节点。因此，我在DC2中有1个节点，整个DC3(4个节点)。我有5个节
浏览 0提问于2016-03-19得票数 1
我刚刚继承了一个有3个节点的系统，一个数据中心的两个复制因子为2，第二个数据中心的复制系数为1，系统从Cassandra 3.9升级到Cassandra 3.11.3。因为升级cqlsh中的任何查询都会返回错误。
ReadTimeout: Error from server: code=1200 [Coordinator node timed out waiting for replica nodes' responses] message="Operation timed out - received only 0 responses." info={'rec
浏览 1提问于2018-09-14得票数 1
回答已采纳
我们正在对cassandra集群进行负载测试(3个节点，复制因子3)，并开始在一个表上接收临时的WriteTimeoutExceptions插入操作：
CREATE TABLE users.by_identity (
account ascii,
domain ascii,
identity text
PRIMARY KEY ((account, domain), identity)
);
我们正在对此表执行inserts with子句。当将一个分区的负载增加到>10个插入/s时，客户端请求开始“超时”：
com.d
浏览 10提问于2016-09-28得票数 3
当我将xml文件写入到Cassandra表列中时，我面对的是exception.Its，一个3节点的集群，所有节点都是up的。
com.datastax.driver.core.exceptions.WriteFailureException: Cassandra failure during write query at consistency LOCAL_QUORUM (2 responses were required but only 0 replica responded, 1 failed)
at com.datastax.driver.core.exceptions.Wr
浏览 0提问于2016-06-22得票数 1
1回答
即使我的查询没有选项，如果存在，如果不存在，你能给我建议吗？仍然在查询跟踪结果中显示两个consistency_level "QUORUM“，这正是我们想要的 但它也显示'serial_consistency_level'：'SERIAL'，这是什么行为 session_id | client | command | coordinator | duration | parameters
浏览 9提问于2019-03-04得票数 0
我设置了一个简单的脚本将一个新记录插入到Cassandra数据库中。它在我的本地机器上工作得很好，但是当我将数据库移到远程机器时，我会从客户端获得超时错误。如何正确设置此驱动程序的超时？我试过很多东西。我黑掉了IDE中的超时值，并让它在没有超时的情况下工作，所以我肯定知道这只是一个超时问题。
如何设置集群：
profile = ExecutionProfile(request_timeout=100000)
self.cluster = Cluster([os.getenv('CASSANDRA_NODES', None)], auth_provider=auth_provid
浏览 0提问于2018-02-06得票数 5
我在使用spark conector在aws keyspace上写入数据时遇到了问题。下面的消息显示： ERROR QueryExecutor: Failed to execute: com.datastax.spark.connector.writer.RichBoundStatementWrapper@681c47f5 com.datastax.oss.driver.api.core.servererrors.WriteTimeoutException: Cassandra timeout during SIMPLE write query at consistency LOCAL_QU
浏览 33提问于2021-09-16得票数 1
1回答
我正在使用Cassandra 2.2，我有一个要求高度一致性的应用程序。
我已经配置了一个包含3个节点的数据中心集群。我的密钥空间是用replication_factor of 2创建的。在每个configuration.yaml文件中，我都设置了2 seed_providers (例如NODE_1和NODE_3)。
重要的是，即使有一个节点关闭，我的应用程序也应该是功能齐全的.
目前，当我的应用程序与集群联系时，我在一致性和超时方面有一些问题。
我已经阅读了整个Cassandra2.2文档，我的结论是，对于我的写操作最好的CONSISTENCY LEVEL应该是QUORUM和read操作ON
浏览 6提问于2016-11-19得票数 1
回答已采纳
1回答
扩展“RequestExecutionException”的“Timeout”类是否与Datastax驱动程序中扩展DriverException的“OperationTimedOut”类相同？
使用python datastax驱动程序进行读写时出现异常:协调器节点等待副本节点响应超时“操作超时-仅收到1个响应。\”info={' received _ responses '：1，'required_responses'：2，'consistency'：'LOCAL_QUORUM'}\""，"pid
浏览 16提问于2019-10-22得票数 0
回答已采纳
我试图通过使用SERIAL一致性来尝试使用Cassandra中的轻量级事务。但是，试图在cqlsh中设置一致性级别会导致错误：
cqlsh:learning> CONSISTENCY SERIAL;
Improper CONSISTENCY command.
WITH CONSISTENCY语句已从CQL中删除，因此我无法使用该语句。是否有一种从cqlsh启用串行一致性的方法？还是我要用司机来做？
浏览 3提问于2015-02-18得票数 1
回答已采纳
实际上，我使用的是Elassandra，它是Cassandra和Elasticsearch的组合。但是这个问题可能来自卡桑德拉(从日志上说)
我有两个节点作为一个数据中心DC1连接起来。我正试图在其中一个节点上安装Kibana。我的Kibana服务器总是说"Kibana服务器还没有准备好“，然后我发现这个错误是关于Cassandra一致性级别的。
我的卡桑德拉system_auth设置为
system_auth
WITH REPLICATION= {'class' : 'SimpleStrategy',
浏览 5提问于2020-09-10得票数 1
我使用Cassandra作为我公司的生产数据库，我有一个读取一致性问题。每天的记录应该是1440，在第一次读取时，它显示600-700多条记录，第二次读取时，它显示1440+记录。我在集群中有3个节点，3个二级索引，请帮助我。我使用了下面的cassandra版本和配置来进行写和读。
Cassandra Version:
1.1.4
Thrift Version:
070
Consistency level
for Read - ALL
for Write - ANY
我已经做了几次尝试，包括增加超时时间，也检查了在每个节点上运行的Nodetool修复仍然没有任何一致性的变化。
浏览 1提问于2012-08-30得票数 1
回答已采纳
2回答
我有3的复制因子和LOCAL_QUORUM的一致性水平。我的机群大小是5。
使用LOCAL_QUORUM，在将数据写入两个节点之后，我的客户端会成功地写入结果。但是对第三个节点的复制是如何发生的，比如cassandra如何选择第三个节点，以及cassandra在第三个节点上没有复制什么？
我需要了解更多关于复制部分的内容。因为如果用于写入的两个节点中有一个失败了，那么我的读取将无法实现LOCAL_QUORUM一致性。
浏览 5提问于2016-08-24得票数 1
回答已采纳
卡桑德拉在码头集装箱里工作。
卡桑德拉版本: 3.11.10。
卡桑德拉-司机-核心: 3.10.2。
卡桑德拉重启策略:除非-停止。
卡桑德拉簇:3个节点。
密钥空间复制因子：{'class'：'NetworkTopologyStrategy'，‘upcloud_pl_waw1 1’：2'}。
一致性级别: LOCAL_QUORUM。
种子:1节。
试验1：
首先，测试创建一个表，然后尝试保存4_000记录。同时，卡桑德拉节点有1分钟的停电。当节点处于上升状态时，测试将继续与保存过程一起进行。毕竟，当您计算表中的所有记录时，您没有4000
浏览 0提问于2023-01-26得票数 2
回答已采纳
1回答
每次我尝试使用cassandra python驱动程序获得查询时，我都会收到这样的异常：
**File "something.py", line 32, in <module>
rows = session.execute('some query execution', timeout=None)
File "C:\Anaconda2\lib\site-packages\cassandra\cluster.py", line 2141, in execute
return self.execute_async(qu
浏览 0提问于2018-05-31得票数 2
回答已采纳
3回答
卡桑德拉LOCAL_QUORUM
、、、、
我在理解/查找有关如何在cassandra中计算各种定额的信息时遇到了问题。
假设我有一个跨2个数据中心使用Network Topology Strategy的16节点集群。每个数据中心的复制因子为2 (DC1: 2，DC2: 2)。
在本例中，如果我使用LOCAL_QUORUM写入，我会将数据写入4个节点(每个数据中心2个)，但何时会出现确认？在写入1个数据中心中的2个节点后？
此外，为了保持强读一致性，我需要写节点+读节点>复制因子。在上面的示例中，如果读取和写入都是LOCAL_QUORUM，我将使用2+2，这将不能保证很强的读取一致性。我的理解正确吗？那么我需要什么级别才能确保强大
浏览 0提问于2015-07-29得票数 7
回答已采纳
我使用以下代码从cassandra查询数据：
from cassandra import ConsistencyLevel
from cassandra.cluster import Cluster
from cassandra.auth import PlainTextAuthProvider
from cassandra.query import SimpleStatement
import pandas as pd
cluster = Cluster(contact_points=['192.168.2.4'],port=9042)
session = cluster.
浏览 0提问于2020-09-24得票数 1
在我的星星之火项目中，我使用星火-sql 3.0.2和星火-卡桑德拉-连接器_2.12:3.1.0以及java8。
当我写到卡桑德拉表时，我面临下面的错误
最近的例外是
在一致性LOCAL_ONE的简单写入查询过程中，Cassandra超时(需要一个副本，但只有0确认写入)
请在com.datastax.spark.connector.writer.AsyncStatementWriter.$anonfun$close$2(TableWriter.scala:282) at scala.Option.map(Option.scala:230) at com.datastax.spark.co
浏览 11提问于2022-07-15得票数 1
这个查询很好，但是如果我更改获取数据的时间，我会得到下面的错误(超过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
Gremlin控制台： gremlin>：远程连接tinkerpop.server conf/emote.yaml ==>Configured localhost/127.0.0.1:8182
gremlin> :remote console
==>All scripts will now be sent to Gremlin Server - [localhost/127.0.0.1:8182] - type ':remote console' to return to local mode
gremlin> graph
==>stand
浏览 13提问于2022-08-18得票数 2
回答已采纳
我试图向Cassandra表添加一个文本列，在alter操作期间，我的java应用程序中有几个请求失败，出现了以下错误：
Cassandra failure during read query at consistency LOCAL_QUORUM \
(3 responses were required but only 1 replica responded, 2 failed)
我在其中一个节点中找到了这个日志：
ERROR [Messaging-EventLoop-3-2] 2022-08-31 14:56:13,486 InboundMessageHandler.java:182
浏览 10提问于2022-09-05得票数 0
在consistency LOCAL_QUORUM读取查询期间Cassandra超时(需要2个响应，但只有0个副本响应)；嵌套异常是consistency LOCAL_QUORUM读取查询期间com.datastax.driver.core.exceptions.ReadTimeoutException: Cassandra超时(需要2个响应，但仅 当我在我的应用程序的一个Cassandra表上执行查询时，我得到了上面的错误。该表有3列promo、store和upc。促销是类型= PrimaryKeyType.PARTITIONED &商店和upc都是类型= PrimaryKeyTy
浏览 18提问于2020-07-03得票数 0
我在两个数据中心安装了cassandra，每个节点有4个节点，复制因子为2。
一致性级别为1(默认设置)
当我试图在一致性级别读取数据时，我遇到了一致性问题。在DataStax文档中，一致性级别(读+写)应该大于复制因子。
我决定将写入一致性级别改为2，读取一致性级别改为1，从而解决了单个数据中心的不一致性问题。但是，在多个数据中心的情况下，问题可以通过一致性级别(如LOCAL_QUORUM )来解决。
我如何实现写应该是(LOCAL_QUORUM +2)，以便我应该写到本地数据中心，也是在2个节点上。
浏览 4提问于2016-10-18得票数 0
回答已采纳
cassandra版本:apache-cassandra-2.1.8
创建超级用户并使用同一个用户成功登录后，我已经创建了一个密钥空间，如下所示
sufian@cqlsh:dbs> CREATE KEYSPACE DBS WITH REPLICATION = { 'class' : 'NetworkTopologyStrategy','dc1' : 2} AND DURABLE_WRITEs =TRUE
并创建了一个表emp为
sufian@cqlsh:dbs> create table emp ( empid int,deptid
浏览 1提问于2015-07-27得票数 2
我们在AWS上有一个具有2个vCPU和大约16 GB RAM的单节点Cassandra Cluster (Apache)。我们有大约28 GB的数据上传到Cassandra。
现在Cassandra可以很好地使用主键进行select和group by查询，但是当使用用户定义的函数在非主键上使用聚合函数时-它会给出超时。
为了详细说明-我们对3年的数据按年、月和日期进行了划分。现在，例如，如果两列是- Bill_ID和Bill_Amount，我们希望使用UDF将Bill_Amount与Bill_ID相加。
这里有点困惑，因为我相信如果信息说它收到了1个响应，如果它已经收到了，为什么要给出超时的消
浏览 0提问于2017-04-26得票数 1
我正在尝试对一个包含各种WHERE子句的大型Cassandra表(10m行)执行SELECT语句。我从Datastax DevCenter应用程序发出这些命令。我在where子句中使用的列有二级索引。 where子句看起来像WHERE fileid = 18000或WHERE fileid < 18000。在本例中，第二个where子句导致错误Unable to execute CQL script on 'connection1': Cassandra failure during read query at consistency ONE (1 responses
浏览 42提问于2019-07-03得票数 0
回答已采纳
我们使用一个多数据中心(DC) cassandra集群。在写入集群期间，我只希望本地DC对其节点执行写操作，因为我们已经将写入请求路由到所需的DC，只基于启动写入的源。因此，我只希望本地DC处理写入，而不希望其他DC对其节点执行写入操作。但后来，由于在各DC节点之间进行复制，我希望在DC之间复制书面数据。当我在第一个place.If中限制只写入一个DC时，在写入操作期间不打开与位于不同DC中的远程主机的连接时，是否有可能在DC之间复制数据。我之所以绝对需要在所有DC中复制数据，是因为在从集群读取数据时，我们希望从读取请求的任何DC读取数据，而不一定是本地请求。
有谁能解决这个问题吗？
浏览 0提问于2018-07-20得票数 3
回答已采纳
下面是我们的表格描述：
、CREATE KEYSPACE statistics
WITH replication = {
'class' : 'SimpleStrategy',
'replication_factor' : 2
};
DROP TABLE IF EXISTS statistics;
CREATE TABLE statistics (
source text,
timespan text,
id text,
title text,
thumbnail text,
url text,
text text,
浏览 4提问于2016-01-11得票数 0
回答已采纳
我收到以下错误。 cassandra.ReadTimeOut: Error from server: code =1200 [Coordinator node timed out waiting for replica nodes' responses] message = Operation timed out - received only 0 responses." info={consistency: 'LOCAL_ONE',required_responses": 1, 'received_responses": 0} 这就是
浏览 50提问于2020-04-09得票数 0
回答已采纳
我对卡桑德拉选择的策略有一个简单的问题，当发生以下情况时
场景
在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
我们已经在亚马逊网络服务中实现了一个四节点的Cassandra集群，现在希望将相同的数据迁移到Azure.currently当我们尝试进行Cassandra复制时，我们观察到它处于活动活动模式，负载在主站点和辅助站点的所有服务器之间进行拆分这会导致在主站点上进行的查询结果中的数据不一致，因为它以某种方式平衡了负载并从辅助站点渲染数据我们希望您的帮助知道这是否可以限制，或者在Cassandra中是否可以进行故障切换同步。任何建议都将不胜感激。谢谢
浏览 2提问于2016-10-13得票数 0
1回答
我正在使用dse驱动程序3.6.8，java 8，spring 3.2.18，我正在尝试为每个表设置不同的一致性级别所需的一致性级别存储在一个propoerty文件中 <entry key="consistency.level.strongWriteLevel">EACH_QUORUM</entry>
<entry key="consistency.level.strongReadLevel">LOCAL_QUORUM</entry>
<entry key="consistency.level.li
浏览 15提问于2021-08-13得票数 1
1回答
我在我的表上执行一些查询，当我执行这个查询时：
select o_type from basic_data where oid4 = 1;
卡桑德拉给我的答案是：
Traceback (most recent call last): File "/usr/bin/cqlsh.py", line 1277, in perform_simple_statement result = future.result() File "cassandra/cluster.py", line 3822, in cassandra.cluster.Response
浏览 8提问于2017-05-22得票数 1
我有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
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
