-
0 votesanswersviews
连接到Lagom Deveoper Box的Cassandra
我正在使用带有Chirper应用程序的Lagom Framework . 应用程序启动并运行 . 据我所知，在开发模式下，默认情况下，Cassandra在端口4000上运行 . 我无法连接到本地Cassandra来浏览数据和事件 . 有关如何连接到lagom附带的嵌入式cassandra的任何指针，以便我可以查看存储的事件 . 本地运行的服务如下 http://localhost:8000/ser... -
3 votesanswersviews
Cassandra：无法用已经引导的节点替换地址
5节点Cassandra（3.9）集群中的一个现有节点未能出现 . 我注意到要关闭的节点并尝试使用该命令重新启动 服务cassandra重启 但节点未能到来，我在 system.log 看到了以下异常 错误[main] 2017-04-14 10：03：49,959 CassandraDaemon.java:747 - 启动时遇到异常java.lang.RuntimeException：无... -
5 votesanswersviews
Cassandra无法初始化类com.sun.jna.Native
我在CentOS 7上使用Cassandra 3.9版 . 在启动Cassandra Server时，我收到的错误就像这样:: TRACE [MemtableFlushWriter：1] 2017-05-15 04：25：49,735 LogTransaction.java:264 - 关闭事务日志[/ var / lib / cassandra / data / system /中的mc_t... -
0 votesanswersviews
DSE cassandra没有开始
面对一个问题，我们在重启后有5个节点的集群dse试图启动而没有成功，system.log中的最后一条记录在下面...尝试用堆和48和64，节点有128GB . 其中三个开始但这两个不能，日志中只有那个记录没有错误 . INFO [主要] 2017-05-16 21:16:27,507 CassandraDaemon.java:487 - JVM参数：[-Ddse.server_process... -
0 votesanswersviews
由于磁盘空间不足，我无法打开Cassandra
我设置了一个新的Cassandra并使用 ./cassandra 打开它，但它失败了 . 在system.log中，它显示以下错误： 错误13:30:31启动时遇到异常java.lang.RuntimeException：java.lang.RuntimeException：java.util.concurrent.ExecutionException：java.lang.RuntimeExcep... -
0 votesanswersviews
在 生产环境 最佳实践中改变Cassandra压缩是nodetool upgradedesstables的首选吗？
我们有一个cassandra键空间，有2个表正在制作中 . 我们已将其压缩策略从 LZ4Compressor （默认值）更改为 DeflateCompressor 使用 ALTER TABLE "Keyspace"."TableName" WITH compression = {'class': 'DeflateCompressor'}; 因为我的cassa... -
0 votesanswersviews
没有列的DSE 5.1.10表..重新启动错误
cassandra重启时面临错误 . ERROR [main] 2018-09-04 03:04:53,490 CassandraDaemon.java:723 - 启动时遇到的异常org.apache.cassandra.schema.SchemaKeyspace $ MissingColumns：org中test.test1的架构表中找不到的列 . apache.cassandra.sc... -
0 votesanswersviews
Cassandra由于org.apache.cassandra.io.FSWriteError而关闭：java.nio.file.NoSuchFileException
Canssandra（2.1.13）在启动时抛出“org.apache.cassandra.io.FSWriteError:java.nio.file.NoSuchFileException” 这是堆栈跟踪： ERROR [MemtableFlushWriter：1] 2018-10-22 03：24：41,191 CassandraDaemon.java:229 - 线程中的异常线程[Mem... -
1 votesanswersviews
Cassandra关闭导致：java.io.SyncFailedException：同步失败
我正在使用Cassnadra 2.1.13单节点集群，数据库运行良好，没有任何问题 . 然后出现了以下异常，因为Cassandra服务被降低了 . 在单个节点集群中，这些异常的原因可能是 sync failed ，是否有任何提示或指针来解决此问题的根本原因？ INFO [MemtableFlushWriter：22] Memtable.java:347 - 编写Memtable-compact... -
0 votesanswersviews
升级后的Cassandra DataStax 5.0 thriftQueries读取失败
最近我们从4.x datastax cassandra迁移到5.1.4 datastax cassandra . 我们使用thriftQueries来编写和读取4.x的数据 . 升级后我们已经能够在cassandra中写入数据但是当我们尝试获取数据时它失败了 . 可能是什么原因？请在下面找到附件日志 . [2018-11-16T20:34:29.020Z] ERROR [L:nemo.inter... -
1 votesanswersviews
Cassandra和Solr集成：无法执行查询
我正在尝试整合cassandra和solr . 我使用的是solr -6.6.0版本，cassandra 3.10版本和java 8 . 在我的solrconfig.xml中，我添加了这些行 <lib dir="/home/bkoganti/solr-6.6.0/contrib/dataimporthandler/" regex="cassandra-jdbc-... -
2 votesanswersviews
Spring Boot应用程序缓慢内存泄漏
我最近部署了一个Spring Boot应用程序，该应用程序计划每天运行，以便从Cassandra集群解析新数据 . 经过大约20个小时的工作（对Cassandra进行了数百万次读/写访问），出现了一些内存问题，并且在每次迭代时（异常都在循环内捕获）我有这样的错误： java.lang.RuntimeException: java.lang.IllegalStateException: java.l... -
2 votesanswersviews
无法将Java日期保存到Cassandra
我尝试使用spark为casandra保存一些数据，但是当我尝试保存Date时，我得到了 线程“main”中的异常org.apache.spark.sql.AnalysisException：无法从field2＃5中提取值; org.apache.spark.sql.catalyst.expressions.ExtractValue $ .apply（complexTypeExtractors.... -
2 votesanswersviews
火花工作cassandra错误
我每次运行带有cassandra连接器的spark中的scala程序时都会收到此错误 Exception during preparation of SELECT count(*) FROM "eventtest"."simpletbl" WHERE token("a") > ? AND token("a") &... -
1 votesanswersviews
外部访问有状态的无头kubernetes？
我在AWS上创建了Cassandra有状态/无头集群，它在集群内部运行良好 . 唯一的问题是我无法从外部群集访问它 . 我在Kubernetes文档或StackOverflow引用上尝试了大部分内容，但仍然无法解决它 . 我有一个来自AWS的工作安全组 . 这是我的服务和有状态的yaml文件 . apiVersion: v1 kind: Service metadata: name: cass... -
2 votesanswersviews
cassandra中的一致性级别调整
想象一下电子商务应用程序： 假设我有三个 Node cluster N1, N2, N3. 并且我的一致性等级（CL）很弱：那就是 Read CL = N/2+1 = 2 (in this case), Write CL = Any (alteast 1) 我有一个产品表，如 这是跨三个节点同步的初始数据 product_info : { 'computer': 1} 现在，客户端A从N1... -
420 votesanswersviews
Cassandra中分区键，复合键和聚类键之间的区别？
我一直在阅读网络上的文章，以了解以下 key 类型之间的差异 . 但这对我来说似乎很难掌握 . 示例肯定有助于更好地理解 . primary key, partition key, composite key clustering key -
1 votesanswersviews
查询所有和一致性
这是关于select *查询的cassandra行为的问题 . 它更多的是为了理解，我知道我不应该执行这样的查询 . 假设我有4个节点，RF = 2 . 下表（列族）：create table test_storage（id text，created_on TIMESTAMP，location int，data text，PRIMARY KEY（id））;我在表格中插入了100个条目 . 现在我通... -
2 votesanswersviews
Cassandra轻量级交易性能惩罚
我有两个cassandra表，一个记录表和一个计数器表 . 计数器表为记录表中的每种记录保留一个计数器 . 当我将新记录插入记录表时，我将同时更新计数器表 . 但新记录可能已经在记录表中 . 可以两次插入相同的记录，但之后我会将计数器添加两次，这是不正确的 . 我现在有两个解决方案 . 使用新记录键从cassandra中获取记录 . 如果它不为null，我将不会插入记录并增加计数器 . 使... -
2 votesanswersviews
Cassandra和用计数器类型清理旧数据
所以我知道TTL因为设计原因而无法用于计数器，我已经阅读了https://issues.apache.org/jira/browse/CASSANDRA-2103以及其他一些有关此问题的SO，但似乎没有明确答案（除非我遗漏了一些完全合理的事情）： 我们如何优雅地处理Cassandra柜台的到期？ 示例用例：特定日期的页面查看 . 为此，我们可能有一个表，如 CREATE TABLE综合浏览量（页面... -
0 votesanswersviews
Cassandra：未正确设置布尔列
应用说明 这是应用程序的逐步说明（请参阅schema附件）： Service1使用来自RabbitMQ的消息 Service1对它执行某些操作然后使用列插入数据（处理为false） Service1从cassandra获取ID（数据只是插入）并在具有ID的专用RabbitMQ队列中推送消息 Service2使用来自专用RabbitMQ队列的消息，做一些事情然后用列INSERT（实际... -
-1 votesanswersviews
读取查询期间的Cassandra失败
我有一个带有~500列的Cassandra表和主键 ((userId, version, shredId), rowId) ，其中 shredId 用于将数据均匀地分配到不同的分区 . 由于数据用于实时聚合，因此表还具有2天的默认TTL以使数据到期 . 压缩策略是TimeWindowCompactionStrategy . 工作流程是： 将数据写入输入表（具有一致性EACH_QUORUM） ... -
1 votesanswersviews
Cassandra读取超时的正确行为是什么？
我们的设置是6个节点，每个DC 3个，每个DC 3个方向复制 . 我们用EACH_QUORUM写 . 尝试使用LOCAL_QUORUM阅读 . 偶尔，我们会收到错误的读取超时： com.datastax.driver.core.exceptions.ReadTimeoutException: Cassandra time out during read query at consistency A... -
1 votesanswersviews
Cassandra简单的主键查询
我们想创建一个带有简单主键的Cassandra表，该表由UUID列组成 . 该表将如下所示：CREATE TABLE simple_table( id UUID PRIMARY KEY, col1 text, col2 text, col3 UUID ); 此表可能会存储几十亿行，并且这些行应在使用TTL功能一段时间（几个月）后过期 . 关于这个表的效率我几乎没有问题： 使用主键查询此表的效率... -
0 votesanswersviews
使用python多处理插入到cassandra db中
我是python和cassandra的新手 . 我试图在cassandra中使用python multiproccessing，我在这个网站上得到它https://github.com/aholmberg/driver-multiprocessing/blob/py3/multiprocess_execute.py如何修复错误，请告诉我是否必须应用任何更改 . 这是我的代码： from multi... -
1 votesanswersviews
在Cassandra插入非常慢
我正在使用Cassandra 1.2.1，我使用COPY命令插入数百万行 . 每行长100个字节 . 问题是插入发生得相当缓慢，速度为每秒1500行 . 我们有3个节点集群，每个集群有50 GB的磁盘空间，每个集群有4 GB的RAM . Cassandra进程正在运行，最大堆大小为1 GB . 我们将提交日志和数据文件存储在同一磁盘上 . 可能是这种行为的原因是什么？任何帮助，将不胜感激 . -
1 votesanswersviews
Cassandra节点无法启动
我有一个cassandra集群，我尝试添加和删除它的节点，以评估调整大小时的吞吐量增益 . 问题是在运行添加和删除节点命令后（我也尝试使用nodetool进行清理），我现在无法添加2个节点，因为我遇到了这个异常： java.lang.IllegalStateException: unable to find sufficient sources for streaming range 和cass... -
0 votesanswersviews
Cassandra插入/写入失败
我已经在CentOS6.5服务器上安装了Cassandra 2.0，并且在测试简单记录时一切正常，现在我必须上传6000亿行，当我在cqlsh上使用COPY时，它在5分钟后失败，并且插入的大约行是20万行rpc超时，然后我选择了pycasso并解析了csv并尝试使用insert命令导入，在每10K记录之后，我们选择关闭连接并再次开发新连接 . 但在大约6万条记录之后，它因超时而失败 . 我的调试跟... -
0 votesanswersviews
Cassandra 缓慢插入
我正在使用java datastax客户端将数据插入cassandra . 现在我正在迭代对象列表并逐行插入 . 每种情况都有不同的行数，但速度对我来说是不可接受的 . 你能否提出改善速度的方法？你认为BATCH插入可能有帮助吗？多线程插入怎么样？ 谢谢你的帮助！ 这是我的 table . CREATE TABLE StatisticsKeyspace.HourlyStatistics( Key... -
2 votesanswersviews
Cassandra批量大小
我有6个主要用于写作的Cassandra节点（95％） . 插入数据的最佳方法是什么 - 单个插入或批量？理由说要使用批次，同时将“批量大小”保持在5kb以下以避免节点不稳定： https://issues.apache.org/jira/browse/CASSANDRA-6487 这些5kb是否与查询的大小有关，就像chars * bytes_per_char的数量一样？完全运行单个插件有任何性...