问题标签 [datastax-enterprise]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
cassandra - 在集群中启动时,datastax 企业异常崩溃
我正在尝试设置 DSE 集群。我的种子节点工作正常,但是当我尝试在集群节点上运行 DSE 服务时,它会崩溃并出现异常
错误 09:46:47,271 在启动 java.lang.IllegalStateException 期间遇到异常:无法联系任何种子!在 org.apache.cassandra.service.StorageService.bootstrap(StorageService.java:947) 在 org.apache.cassandra.service.StorageService.joinTokenRing(StorageService.java:716) 在 org.apache.cassandra.service.StorageService.initServer (StorageService.java:554) 在 org.apache.cassandra.service.StorageService.initServer(StorageService.java:451) 在 org.apache.cassandra.service.CassandraDaemon.setup(CassandraDaemon.java:347) 在 com.datastax。 bdp.server.DseDaemon.setup(DseDaemon.java:137) 在 org.apache.cassandra.service.CassandraDaemon.activate(CassandraDaemon.java:446) 在 com.datastax.bdp.server.DseDaemon.main(DseDaemon.java: 334)java.lang.IllegalStateException:无法联系任何种子!在 org.apache.cassandra.service.StorageService.bootstrap(StorageService.java:947) 在 org.apache.cassandra.service.StorageService.joinTokenRing(StorageService.java:716) 在 org.apache.cassandra.service.StorageService.initServer (StorageService.java:554) 在 org.apache.cassandra.service.StorageService.initServer(StorageService.java:451) 在 org.apache.cassandra.service.CassandraDaemon.setup(CassandraDaemon.java:347) 在 com.datastax。 bdp.server.DseDaemon.setup(DseDaemon.java:137) 在 org.apache.cassandra.service.CassandraDaemon.activate(CassandraDaemon.java:446) 在 com.datastax.bdp.server.DseDaemon.main(DseDaemon.java: 334)启动过程中遇到异常:无法联系任何种子!错误 09:46:47,279 线程 Thread[StorageServiceShutdownHook,5,main] java.lang 中的异常。
有人可以帮我解决这个问题吗?
杰尼什
python - 如何为我的两节点 Cassandra 集群生成令牌?
我正在尝试在 Windows 机器上设置两个节点 Cassandra 集群。我基本上有两台 Windows 机器,我正在关注这个 datastax教程
每当我使用以下命令从上述教程中获取令牌编号时 -
我总是收到这个错误 -
solr - 无限搜索集群(Solr vs ES vs Datastax EE)
前言:
这个问题并不是要求对 Elastic Search 与 Solr 与 Datastax Solr (Datastax EE) 进行开放式比较。(尽管欢迎评论部分中的链接)。
项目:
我一直在构建域名类型的 Web 服务。在这样做的过程中,我意识到这种服务的指数级增长。
背景:
我想知道哪个特定的搜索平台可以让我无限地保存和扩展。是的,我意识到这些天你可以拆分一个 Solr Shard——所以如果我有一个 20 个 shard 的 solr 云,我以后可以将它们拆分成 40 个(我认为?再次......这不是不确定的)。不确定在弹性搜索方面。由于 Cassandra 的架构,Datastax (EE) 似乎是答案,但是 (A) 因为他们没有提供许可证价格的透明度——我必须披露我的收入对他们来说,我很快就想起了甲骨文的“让你慢慢流血”的策略,在我刚起步时,这是一个巨大的威慑。另外,(B) 当他们说他们将完整的 MapReduce 与 Hive、Sqop、Mahout、Solr 和 Pig 集成在一起时——我想我不想花一生的时间来学习那些不适用于我的项目的花里胡哨。我想要一个搜索平台,我可以在一个月内无限期地添加 20 亿个文档(或任何数量),而不必担心我启动的集群前期分片太少。
问题:
诚然,我的背景部分被盗用了我想纠正的无知。我的目的不是冒犯或淡化这些惊人的技术。我只是想知道它们中的哪些可以扩展而不必担心碎片过度增长[我在这里永远删除了这个词——谢谢你在下面的评论]。或者可以吗?不是硬件方面的,而是碎片。我可以使用哪个平台,而不必担心未来的增长是 20TB 还是 2PB。假设服务器、交换机等的硬件预算是不确定的。
cassandra - 插入后的意外值
我有一个用 python 编写的脚本,应该更新 Cassandra 中的计数器。它就像一个批纠正计数器。
脚本所做的是:获取应该在数据库中的真实值,获取在数据库中持久保存的当前值,计算值之间的差异,最后将插入命令发送到传递差异的特定行键以更新计数器。
一切正常。我得到了正确的值和差异,但是在插入命令之后,行键的值不是预期的。
我发送了通过 diff=5000 的插入命令,因此预期的新 DB 值应该是 35000。但有时新的 DB 值是一个疯狂的负数,例如 -360.000。这没有任何意义,因为没有任何值和运算符的组合可以产生这样的值。
而且,如果我再次运行脚本,最终的持久值是正确的。如果我稍后再试一次,最终的持久值再次出现错误......
谁能帮我这个 ?相同的脚本有时可以正常工作,有时会保持疯狂的价值。
谢谢 !
apache-pig - PigLatin 重命名元组
我正在加载数据并创建一个元组:
后来我想重命名元组,这样我就有了
有没有可能?
hadoop - 数行 Cassandra->Hadoop 输入不同
我在 2 节点集群上有一个具有 147.968 行的 ColumnFamily(显示“nodetool cfstats”)。
如果我执行我的 Hadoop 作业,他在“地图输入记录”上只显示 90.174 行?我的 Hadoop CQL 输入配置是:
还有什么要配置的吗?
ssl - Cassandra 抛出 SSLFactory.java 警告
我们将 dse 3.1.4 与 server_encryption_options 一起使用。
server_encryption_options:
我们将 java 安全库添加到 /lib/security 但我们仍然看到
谁能告诉我为什么会这样?
cassandra - Cassandra 为一个集群显示了两个不同的环
我们有一个 3 个节点的 cassandra 集群。昨天我停止了其中一个节点,今天又重新启动了它。令人惊讶的是,现在我有了新节点的不同环。为什么它显示为不同的铃声并且日志中没有错误消息。
环 1:节点工具状态
联合国 1.2.3.4 联合国 5.6.7.8
环 2:节点工具状态
联合国 9.10.11.12
当我看到 ring 1 的日志时,两个节点都显示相同的消息:
WARN [WRITE-/9.10.11.12] 2013-11-05 14:04:51,221 SSLFactory.java(第 139 行)过滤掉 TLS_RSA_WITH_AES_256_CBC_SHA,因为它不受套接字支持
戒指 2:
它没有错误
两个集群名称相同,都在同一个网络中,三个节点都是种子节点。任何帮助,将不胜感激。
cassandra - Cassandra 节点因 Java 堆错误而关闭
WARN [ScheduledTasks:1] 2013-11-04 22:51:06,619 GCInspector.java(第 142 行)堆已满 0.892615008651467。您可能需要减少 memtable 和/或缓存大小。Cassandra 现在将刷新到两个最大的内存表以释放内存。如果您不希望 Cassandra 自动执行此操作,请调整 cassandra.yaml 中的 flush_largest_memtables_at 阈值
WARN [ScheduledTasks:1] 2013-11-04 22:51:06,633 StorageService.java (line 3600) Flushing CFS(Keyspace='OpsCenter', ColumnFamily='rollups60') 以缓解内存压力 INFO [ScheduledTasks:1] 2013- 11-04 22:51:06,634 ColumnFamilyStore.java(第 630 行)排队刷新 Memtable-rollups60@573393486(240/4340 序列化/实时字节,15 个操作)
错误 [Thrift:46] 2013-11-04 22:51:06,621 CassandraDaemon.java(第 192 行)线程中的异常
线程 [Thrift:46,5,main] java.lang.OutOfMemoryError: java.util.Arrays.copyOf(Unknown Source) at java.io.ByteArrayOutputStream.write(Unknown Source) at org.apache.thrift 的 Java 堆空间。 org.apache.cassandra.thrift.TBinaryProtocol.writeBinary(TBinaryProtocol.java: 73) 在 org.apache.cassandra.thrift.ColumnOrSuperColumn.write(ColumnOrSuperColumn.java:554) 在 org.apache.cassandra.thrift.Cassandra 的 org.apache.cassandra.thrift.Column.write(Column.java:579) $get_slice_result.write(Cassandra.java:7900) 在 org.apache.thrift.ProcessFunction.process(ProcessFunction.java:34) 在 org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:34) 在 org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:201) 在 java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source) 在 java.util.concurrent.ThreadPoolExecutor$Worker。在 java.lang.Thread.run(Unknown Source) INFO [FlushWriter:20] 2013-11-04 22:51:06,635 Memtable.java (line 495) 处运行(Unknown Source) 已完成刷新 /data/OpsCenter/rollups60/OpsCenter -rollups60-ic-889-Data.db (519 字节) 用于提交日志位置 ReplayPosition(segmentId=1383597360912, position=10472305)运行(未知来源)INFO [FlushWriter:20] 2013-11-04 22:51:06,635 Memtable.java(第 495 行)已完成刷新 /data/OpsCenter/rollups60/OpsCenter-rollups60-ic-889-Data.db (519 bytes) 用于提交日志位置 ReplayPosition(segmentId=1383597360912, position=10472305)运行(未知来源)INFO [FlushWriter:20] 2013-11-04 22:51:06,635 Memtable.java(第 495 行)已完成刷新 /data/OpsCenter/rollups60/OpsCenter-rollups60-ic-889-Data.db (519 bytes) 用于提交日志位置 ReplayPosition(segmentId=1383597360912, position=10472305)
INFO [FlushWriter:20] 2013-11-04 22:51:06,639 Memtable.java(第 461 行)写入 Memtable-rollups300@1479174915(288/5560 序列化/实时字节,12 个操作)
INFO [StorageServiceShutdownHook] 2013-11-04 22:51:06,683 Server.java(第 160 行)停止侦听 CQL 客户端 INFO [StorageServiceShutdownHook] 2013-11-04 22:51:06,684 Gossiper.java(第 1108 行)宣布关闭
当压缩正在进行时,我的节点会死掉。我的 max_heap_size 为 8G,但我仍然不知道如何配置我的堆大小。
cassandra - 如何检查 Gazzang 是否正在加密我的 cassandra 数据?
我们有一个带有 gazzang 的 4 节点 cassandra 集群。我想知道如何加密数据并检查数据是否加密?