标签: datastax-enterprise

我正在尝试使用Datastax Enterprise,我正在尝试使用一个混合Enterprise节点和标准Cassandra社区节点的集群.我只需要一些具有Solr等高级功能的节点,将所有节点放在同一个集群中会很不错.

我尝试将社区节点引导到测试企业集群,它无法正确加入环,抛出类似的异常:

Unable to find compaction strategy class 
'com.datastax.bdp.hadoop.cfs.compaction.CFSCompactionStrategy'

我假设Enterprise节点尝试复制具有DSE功能的CF,社区节点无法识别这些功能.

有没有办法防止这种情况发生？我是否尝试做一些DSE不可能/不支持/允许的事情？

我正在尝试使用Windows 7机箱上的Datastax C#客户端驱动程序连接到在虚拟机(Ubuntu)上运行的DSE Cassandra.这是我的代码:

Cluster _cluster = Cluster.Builder()
                      .WithPort(9042)
                      .AddContactPoint("192.168.1.136")
                      .Build();

我收到此错误:所有尝试查询的主机都出错(尝试:192.168.1.136)

我认为问题是远程机器(在这种情况下是一个虚拟盒子)不接受连接.

有没有人从Windows 7上的c#驱动程序连接到在虚拟机上运行的远程Ubuntu？

从最近几周开始,我一直在研究Elasticsearch和Solr,并尝试实时进行OLTP处理.然而,对我来说,他们声称(特别是ES)是实时的.对我来说,实时的意义看起来很模糊.

如果我们深入研究它,ES和Solr都会定义刷新率或软提交率,之后新索引的文档可用于搜索,有效地仅提供近实时功能.

它看起来像是通过实时搜索,它可以是实时调用它的营销声明,也可以通过谈论实时搜索而不是批处理或分析处理来使单词模糊.

如果我错了,我是否正确或纠正我,并且在典型的OLTP系统中可以进行实时搜索,其中每个事务都具有对最后文档的搜索可见性？

我们的表中有一个主键UUID.要获得最后一条记录,我们按desc uuid字段排序.但是,因为此字段不是整数,所以我们始终不会获得最后一条记录.有没有办法获得最后的记录？请注意,我们不想制作群集列.

这是我的桌子

ArtistId (partition key)  | SongId (primary key, uuid) |  Song
--------------------------------------------
1                         | 9a9fa429-c349-4137         |  abc
1                         | 9a9fa429-b349-6137         |  cde
1                         | 9a9ga429-a349-6132         |  fgh
2                         | 249ga429-a909-6542         |  ijk
2                         | 249kg429-a239-3652         |  lmn
1                         | i55oa429-a909-3462         |  opq
1                         | e4235k59-4ik9-6542         |  rst

我昨天从Datastax Enterprise 4.5.1升级到4.7.3.现在我在system.log中看到了这个ERROR的几个实例.我认为这是在"nodetool修复"期间发生的.

ERROR [Reference-Reaper:1] 2015-10-02 18:13:02,747 Ref.java:179 - LEAK DETECTED: a reference (org.apache.cassandra.utils.concurrent.Ref$State@312122cd) to class org.apache.cassandra.io.sstable.SSTableReader$InstanceTidier@1310889366:/data/lib/cassandra/data/reporting/summaries/snapshots/d7c61b70-6921-11e5-9215-6dd40f18e7fa/summaries-ka-1196 was not released before the reference was garbage collected

我应该在哪里开始排除此错误？

[cqlsh 5.0.1 | Cassandra 2.1.8.689 | DSE 4.7.3 | CQL spec 3.2.0 | Native protocol v3]

我希望停用 cassandra 节点，因为该节点需要操作系统升级。

我登录到该节点。执行退役命令，几分钟后我在控制台上收到此异常

nodetool decommission

error: Stream failed
-- StackTrace --
org.apache.cassandra.streaming.StreamException: Stream failed
    at org.apache.cassandra.streaming.management.StreamEventJMXNotifier.onFailure(StreamEventJMXNotifier.java:85)
    at com.google.common.util.concurrent.Futures$4.run(Futures.java:1172)
    at com.google.common.util.concurrent.MoreExecutors$SameThreadExecutorService.execute(MoreExecutors.java:297)
    at com.google.common.util.concurrent.ExecutionList.executeListener(ExecutionList.java:156)
    at com.google.common.util.concurrent.ExecutionList.execute(ExecutionList.java:145)
    at com.google.common.util.concurrent.AbstractFuture.setException(AbstractFuture.java:202)
    at org.apache.cassandra.streaming.StreamResultFuture.maybeComplete(StreamResultFuture.java:208)
    at org.apache.cassandra.streaming.StreamResultFuture.handleSessionComplete(StreamResultFuture.java:184)
    at org.apache.cassandra.streaming.StreamSession.closeSession(StreamSession.java:412)
    at org.apache.cassandra.streaming.StreamSession.onError(StreamSession.java:507)
    at org.apache.cassandra.streaming.StreamSession.start(StreamSession.java:229)
    at org.apache.cassandra.streaming.StreamCoordinator$StreamSessionConnector.run(StreamCoordinator.java:208)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
    at java.lang.Thread.run(Thread.java:745)

我不确定那个异常是什么意思，我打算通过nodetool netstats和nodetool status来验证退役是否成功，其输出在下面。在两个地方都说LEAVING，我如何确认它是否完整。

nodetool netstats
Mode: LEAVING
Not sending any streams.
Read Repair Statistics:
Attempted: 1
Mismatch (Blocking): 0
Mismatch (Background): 0
Pool Name                    Active   Pending      Completed
Commands                        n/a …

如果架构已满或无架构,我感到困惑DataStax graph .

我问这个问题,因为 入门教程 告诉创建架构.但我key-value在边缘属性上插入随机并DSE graph接受它而没有错误.

如果我在DSE-Graph上插入随机Vertex或edge属性(键值)会有问题吗？

我正在尝试使用python(在Windows上)安装cassandra-driver但是它失败并出现以下异常.有人可以帮我这个,

我也尝试过以下位置提到的手动安装过程及其相同的错误, http://datastax.github.io/python-driver/installation.html

安装例外:

C:\Windows\System32>pip install cassandra-driver
Collecting cassandra-driver
  Using cached cassandra-driver-3.9.0.tar.gz
Requirement already satisfied: six>=1.6 in c:\python27\lib\site-packages (from c
assandra-driver)
Requirement already satisfied: futures in c:\python27\lib\site-packages (from ca
ssandra-driver)
Building wheels for collected packages: cassandra-driver
  Running setup.py bdist_wheel for cassandra-driver ... error
  Complete output from command c:\python27\python.exe -u -c "import setuptools,
tokenize;__file__='c:\\users\\user01\\appdata\\local\\temp\\pip-build-pa7rph\\
cassandra-driver\\setup.py';f=getattr(tokenize, 'open', open)(__file__);code=f.r
ead().replace('\r\n', '\n');f.close();exec(compile(code, __file__, 'exec'))" bdi
st_wheel -d c:\users\user01\appdata\local\temp\tmpbqprncpip-wheel- --python-ta
g cp27:
  Unable to find pgen, not compiling formal grammar.
  warning: no files found matching …

有没有办法测试复制完成所需的时间？例如,如果我有一个9节点集群(每个3个dc的3个节点,复制因子为3/3)并使用Local_Quorum进行插入,那么是否有一个度量标准显示该数据复制到所有副本所需的时间？

我想在特定时间后从 Cassandra 集群中删除记录。那么我应该使用TTL还是手动删除呢？