-
0 votesanswersviews
尝试通过单元在Cassandra中创建列族时出现InvalidQueryException
我有一个3节点cassandra集群,通过我在Java中的单元测试,我首先创建一个键空间,然后在该键空间内创建一个列族 . 有时单元测试通过但随机我不断收到以下错误 . 我在2.1.0中使用最新的datastax 2.1.4 java驱动程序和cassandra版本 . com.symc.edp.database.nosql.NoSQLPersistenceException: com.datas... -
0 votesanswersviews
做sstablesplit一边
由于sstables是不可变的,sstable split必须离线执行,即 . 节点关闭 . 是不是也可以离线/在边线目录中拆分极大sstables的副本,同时保持一个节点在线然后在一个节点的短暂重启期间用一组分裂的sstable文件交换极端sstables以最小化节点停机时间? 或者最好是停用一个节点,在其余的集群上传播数据,然后重新加入一个新的空节点 例如 . 有一些大的sstables,很快... -
0 votesanswersviews
Cassandra抛出OutOfMemory
在我们的测试环境中,我们有一个1节点的cassandra集群,RF = 1用于所有键空间 . 感兴趣的VM参数列在下面 -XX:CMSClassUnloadingEnabled -XX:UseThreadPriorities -XX:ThreadPriorityPolicy = 42 -Xms2G -Xmx2G -Xmn1G -XX:HeapDumpOnOutOfMemoryError -Xss... -
0 votesanswersviews
Titan / Cassandra读取可扩展性,随机服务器关闭或丢弃消息
我们正在使用支持的 Titan-1.0.0 作为 cassandra 2.1.7 . 该集群由36个虚拟机组成,每个虚拟机具有16GB RAM(6GB堆)和16个CPU核心 . 我们使用SSD磁盘用于cassandra数据,使用普通HDD用于提交日志 . RF为3,读/写每个CF = 2 . Java版本是1.8.0_45通过此群集提供大量读取 . 在服务器停机的第一天,我们面临着一些服务器... -
4 votesanswersviews
Cassandra Titan / JanusGraph原子性
我们计划使用Cassandra和Titan / JanusGraph db的组合作为我们项目的后端 . 作为其中一部分,我有以下要求 . 应该以原子方式将记录/顶点A和记录/顶点B写入后端,即,既写入记录,也不写入任何记录 . 基本上,我需要进行多行原子写入 . 但是,根据下面列出的Titan和Cassandra的文档,这是我发现的 . Titan DB Titan交易不一定是ACID . 它们可... -
6 votesanswersviews
datastax opscenter代理不安装
我在127.0.1.1上运行自己的cassandra版本 . 我将 rpc_address 和 address 更改为127.0.1.1 . 当我开始 Opscenter 时,我被提示安装 agents ,我是按照推荐的 Fix now 选项安装的 . 但是当我尝试安装它时,我会询问一些Node ssh凭据 . 我不知道这意味着什么 . What are the correct credent... -
1 votesanswersviews
如何从cassandra 2.1中的缓存中清除准备好的语句
我正在尝试使用来自datastax的nodejs驱动程序在cassandra 2.1.2中向用户定义的类型添加字段 . 我在cqlsh中使用 ALTER TYPE 添加了该字段 . 当我尝试添加包含带有新字段值的udt的行时,它将插入null值,而不是我提供的值 . 我强烈怀疑这与集群缓存预准备语句的方式有关 . 因为我记得读过准备好的语句是通过查询的哈希索引的,所以我尝试更改查询中的一些空格以查... -
0 votesanswersviews
Cassandra选择ttl()的TTL值不正确
I have a 3 node cluster with replication factor : 2. 考虑的列族有 default_time_to_live = 3600 哪个是使用alter table设置的: cqlsh:summary> alter table match with default_time_to_live=3600; 将数据插入columnfamily并立即查询后... -
1 votesanswersviews
Cassandra 与阿帕奇火花
我想对存储在Cassandra中的时间序列数据进行一些分析查询和一些范围查询 . 对于tgis,我遇到了Apache Spark,它支持所有这些东西 . 我是否知道如何将apache spark与Cassandra集成并进行查询? 我熟悉Java / J2EE,SQL和CQL的东西,但不熟悉scala.will为这个poc学习scala会不会很好?我正在使用Cassandra 2.2 . -
0 votesanswersviews
Cassandra-Java-driver:com.datastax.driver.core.exceptions.InvalidTypeException:类型无效,列是列表但提供了类java.lang.String
我在Cassandra中有一个用户定义的类型,我在CQLSH中使用以下语法创建: CREATE TYPE order_items ( qty int, name text, milk_type text, size text, price decimal ); 现在在我的表中,我存储了一个类型为“order_items”的列表,因此我可以为一个对象存储多个... -
0 votesanswersviews
Cassandra nodetool compact没有任何反应
我希望从特定的表中删除大量的行 我做了以下步骤:1)为表设置gc_grace_seconds = 0 2)删除大量行~1万3)Ran ./nodetool compact keyspace_name table_name 但是,当我运行nodetool compact(步骤3)时,没有任何反应 . 它不会开始压缩 . 由于大量的墓碑,我的大多数请求现在都会超时 . 该表具有以下设置: AND bl... -
0 votesanswersviews
在 生产环境 最佳实践中改变Cassandra压缩是nodetool upgradedesstables的首选吗?
我们有一个cassandra键空间,有2个表正在制作中 . 我们已将其压缩策略从 LZ4Compressor (默认值)更改为 DeflateCompressor 使用 ALTER TABLE "Keyspace"."TableName" WITH compression = {'class': 'DeflateCompressor'}; 因为我的cassa... -
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... -
0 votesanswersviews
批量插入在Cassandra中使用Apache Spark挂起并且当从Web Ser触发时不关闭上下文
我是新来的火花 . 我正在尝试使用spark-cassandra连接器将csv文件插入到cassandra表中,如下所示:文件在Hdfs中,我获取所有文件的路径,并且我为每个路径调用一个方法,它将csv数据转换为corressponding cassandra数据types并创建一个预准备语句将数据绑定到预准备语句并将其添加到批处理中 . 最后,我在1000时执行批处理 . 关键点1.我使用的是A... -
0 votesanswersviews
在Cassandra中更新表时间歇性地出现InvalidQueryException
我面临着一个特殊的问题 . 我们已经设置了LOCAL_QUORUM的一致性 . 我有一个长期运行的工作,不时更新数据库 . 在这些更新之间,我们间歇地看到以下问题: com.datastax.driver.core.exceptions.InvalidQueryException: SERIAL is not supported as conditional update commit consi...