我正在编写一个Java客户端，它测试读取百万行大小的数据。我正在过滤来自列映射中的键的数据。代码正在正确地创建和插入数据，但它无法读取数据。); cluster.close();}
错误是com.datastax.driver.core.exceptions.ReadFailureException: Cassandra failure during read query
浏览 3提问于2016-07-29得票数 0
我使用Apache从Cassandra读取数据，而卡桑德拉是基于标记范围的扫描。但是，最近我在从卡桑德拉表读取数据的过程中看到了很多故障。阅读失败的原因如下：at com.datast
浏览 3提问于2020-05-13得票数 2
回答已采纳
问题com.datastax.driver.core.exceptions.ReadFailureException: Cassandra failure(ReadFailureException.java:85)
at com.datastax.driver.
浏览 4提问于2016-10-06得票数 2
回答已采纳
1回答
我们有3个Node Cassandra簇，复制3。一些时间回卡桑德拉(1节点)是下降了2天。现在我们无法读取来自Cassandra集群的数据原因是：com.datastax.driver.core.exceptions.ReadFailureException:卡桑德拉在读取查询过程中出现一致性错误(需要1次响应，但只有0次响应)，com.datastax.driver.core.exceptions.ReadFailureException.
浏览 3提问于2016-09-01得票数 0
columnFamilyName) throws IOException{ .read()
.format("org.apache.spark.sql.cassandraCaused by: com.datastax.driver.core.exceptions.ReadFailureException: Cassandra failure during read queryrequired but only 0 replic
浏览 0提问于2019-09-17得票数 0
4回答
我打算使用apache将数据读/写到cassandra，使用flink。我希望使用，但没有找到用于连接器的好文档/示例。
请您指出使用Apache从cassandra读取和写入数据的正确方法。apache也是用于从cassandra读取数据的，是否与apache类似？
浏览 7提问于2017-03-06得票数 4
回答已采纳
我想创建一个异常工厂当连接到数据存储时，我将使用try，catch抛出模式；例如，对于CassandrastoreException = StoreServiceExceptionFactory.getTransientException(ex);
浏览 3提问于2017-07-07得票数 0
回答已采纳
) WITH CLUSTERING ORDER BY (meas_type_id ASC, read_time DESC) 'class': 'org.apache.cassandra.db.compaction.DateTieredCompactionStrategy: Cassandra failure during read query at consistency LOCAL_ONE (1 responses were required but only 0
浏览 23提问于2016-08-31得票数 0
我们正在使用Astyanax读取数据。如果我们的应用程序尝试同时从10行或更多行读取80,000列，一些节点将耗尽堆空间并以OOM错误终止。$SocketThread.run(MessagingService.java:882)
每列中的数据小于50个字节。添加所有列开销(列名+元数据)后，不应超过100个字节。因此，从10行读取80,000列意味着我们正在读取80,000 * 10 * 100 = 80 MB的数据。它很大，但不足以填满1.8GB的堆
浏览 0提问于2013-06-21得票数 2
如何在spark 2.0中从Cassandra Datastax中读取数据？这就是我试过的-
val df = spark.read.format("org.apache.spark.sql.cassandra").options(Map("keyspace" -> "my_keyspace" java.lang.ClassNotFoundException: Failed to find data source: org.apac
浏览 5提问于2020-09-03得票数 0
我们有一个20节点的Cassandra集群，运行着大量的读请求(峰值约为900k/秒)。我们的数据集相当小，因此所有内容都直接从内存(OS Page Cache)提供服务。我们的数据模型非常简单(只有一个键/值)，并且我们所有的读取都是以一致性级别1(Rf3)执行的。我们使用带有TokenAwarePolicy的Java Datastax驱动程序，因此我们所有的读取操作都应该直接转到一个包含请求数据的节点。这些是从其中一个节点提取的关于客户端读取请求
浏览 1提问于2017-11-03得票数 2
我有一个使用spark -sql将数据写入cassandra表的场景。我有一个3节点的cassandra集群。dd, c_code, company_id )我正在尝试将数据插入数据被正确插入。replica responded, 1 failed)
at com.datastax.driver.core.exceptions.ReadFail
浏览 3提问于2019-01-11得票数 0
数据源org.apache.spark.sql.cassandra不支持流式读取 .builder() .config("spark.cassandra.connection.host", "localhost")
.config("spark.cassandra.connection.p
浏览 0提问于2020-10-11得票数 1
1回答
理想情况下，每个分区都应该为它所持有的数据创建SSTable，以便尽可能地并行化进程(甚至可能还会将其流到Cassandra环)。java.lang.RuntimeException: Attempting to load already loaded column family customer.rawts at org.apache.cassandra</em
浏览 1提问于2014-06-24得票数 3
回答已采纳
1回答
我有一个包含5个节点和writeConsistency: LOCAL_QUORUM的Cassandra集群。该集群有TB级的数据。现在，我需要将数据迁移到同一集群中的不同keyspace。现在我们可以通过一些多实例微服务来做到这一点，我们可以从keyspace_1读取数据，然后转换数据，然后将其插入到目标键空间中。 但是有没有更好的方法呢？我找到了一篇文章How to migrate data from Cassandra cluster of size N to a
浏览 39提问于2020-01-22得票数 1
回答已采纳
我正在使用apt在debian上安装Cassandra 1.2.3，我之前使用的是tarball 1.1.7安装。安装后，我将分区程序从Murmur3Partitioner更改为cassandra.yaml中的RandomPartitioner，如下所示：
分区程序: org.apache.cassandra.dht.RandomPartitioner-1；分区程序org.apache.cassandra.dht.Murmur3Partitioner与系统分区程序org.apac
浏览 4提问于2013-04-08得票数 3
回答已采纳
1回答
我正在使用它作为我的网站事件分析(时间序列数据)，有大约1GB的每日数据，有一个3的复制因子。AND comment = ''
AND compaction = {'c
浏览 1提问于2016-07-15得票数 2
回答已采纳
3回答
最近我一直在阅读Apache Cassandra，了解它是如何工作的，以及如何将它用于IoT项目，特别是在需要基于时间序列的数据库的情况下。然而，我开始注意到，当人们谈论Cassandra时，经常会提到Cassandra。问题是，只要我可以使用Cassandra节点集群服务我的应用程序，存储和读取数据，我为什么需要Apache Spark？任何有用的用例，我们都很感激！
浏览 5提问于2016-10-03得票数 2
回答已采纳
1回答
我们想要计算在没有Opscenter的情况下，每秒或每天有多少记录被写入/读取到我们的cassandra集群。
浏览 1提问于2014-05-13得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
