作为对这个问题的跟进:
我想了解,我得到了Request timed Out错误,如果我在服务器日志中看到,我只得到以下错误。
ERROR [SharedPool-Worker-34] 2018-06-01 10:40:36,589 ErrorMessage.java:338 - Unexpected exception during request
java.lang.RuntimeException: org.apache.cassandra.exceptions.ReadTimeoutException: Operation timed out - received only 0 res
我目前正在处理一个服务器进程,它将连接到Cassandra数据库并将信息转发给它。这个过程被写成一个类,我的目标是为这个类创建一个单独的Cassandra会话,它可以用来发送信息。但是,我遇到了一个问题;当我在类init方法中创建Cassandra会话,然后尝试在另一个方法中使用该会话时,我得到以下错误:errors={}, last_host=<server IP address>。目前,我可以通过每次调用该方法时创建一个新的Cassandra会话来解决这个问题,但是这显然不是一个好方法。那么,我如何才能使卡桑德拉会话,我可以在全班持续使用?
此代码不起作用:
from cass
我的目标是通过编写自定义QueryHandler实现来记录每个会话的唯一查询,因为在我们的例子中,记录所有查询会导致性能下降。
考虑这样的情况:如果一个用户使用java客户端连接到cassandra集群,并执行了100次"select * from users where id = ?“。以及从cqlsh连接的另一用户并执行相同的查询50次。因此,在这种情况下,我只想记录两个查询。为此,我每次登录都需要一个唯一的会话id。
Cassandra提供了下面的接口,所有的请求都在其中,但是它的apis都没有提供任何sessionId来区分上面描述的两个不同的会话。
org.apache.ca
我第一次使用Cassandra,但有在像SQLAlchemy这样的库中设置ORMS的经验。在之后,我使用cassandra.cqlengine.models.Model类作为基类设置了我的表,并使用sync_table来设置它,例如:
from cassandra.cqlengine import columns
from cassandra.cqlengine.models import Model
from cassandra.cqlengine.management import sync_table
class Message(Model):
id = columns.Tex
我试图使用Hector插入记录,并不时地得到以下错误:
me.prettyprint.hector.api.exceptions.HUnavailableException: : May not be enough replicas present to handle consistency level.
at me.prettyprint.cassandra.service.ExceptionsTranslatorImpl.translate(ExceptionsTranslatorImpl.java:59)
at me.prettyprint.cassandra.conne
Cassandra无法启动,错误:打开的文件太多。(apache-cassandra-1.2.4)
错误文件包含:
ERROR 11:53:11,893 Exception encountered during startup
java.lang.RuntimeException: java.io.FileNotFoundException: /home/analysis.engine/cassandra/data/system/schema_columnfamilies/system-schema_columnfamilies-ib-289887-Data.db (Too many open
当有30个或更多并发请求...How来解决上述错误时,我会遇到诸如“创建子事件循环失败/未能打开新的选择器/打开太多文件”之类的错误。我做错什么了吗?我使用Spring引导和Java cassandra驱动程序。下面的是连接文件:
public class Connection {
public static Session getConnection() {
final Cluster cluster = Cluster.builder().addContactPoint(ConnectionBean.getCASSANDRA_DB_IP())
.with
I started up a spring container with both cassandra configuration and spring data neo4j configuration, but while starting up, following exception is noticed:
Could not convert argument value of type [org.springframework.data.cassandra.core.cql.session.DefaultSessionFactory] to required type [or
当使用./bin/cassandra -f时,它显示:
Cz@z-EX465-MX:~/cassandra$ ./bin/cassandra -f
INFO 09:12:19,460 Logging initialized
INFO 09:12:19,484 Heap size: 1033895936/1033895936
INFO 09:12:19,486 JNA not found. Native methods will be disabled.
INFO 09:12:19,501 Loading settings from file:/home/z/cassandra/conf
我使用的是DataStax Java Driver 2.17,我得到了这个错误:
Caused by: io.netty.channel.ChannelException: Unable to create Channel from class class io.netty.channel.socket.nio.NioSocketChannel
at io.netty.bootstrap.AbstractBootstrap$BootstrapChannelFactory.newChannel(AbstractBootstrap.java:455) ~[netty-transport-4
我正在尝试从一个特定的表中从Cassandra获取数据,并在做了一些更改后试图将它插入Cassandra中的另一个表中。这两个表都位于键空间"test“中。当我试图从第一个表中获取数据时,一切正常,并且能够获取数据。但是,在处理第一个查询的输出的未来处理程序中,我试图将数据插入到同一个Cassandra实例下的另一个表中,而它正在获取失败。我从应用程序中得到一个错误,上面写着"cassandra.cluster.NoHostAvailable:(“无法使用密钥空间‘test’连接到任何服务器,‘127.0.0.1’)。我不知道我哪里出了问题
import threading
f
我在我的Cassandra Java客户端中得到了下面的错误。
java.util.concurrent.ExecutionException: org.springframework.cassandra.support.exception.CassandraConnectionFailureException: [DNS/IP:PORT] Connection has been closed; nested exception is com.datastax.driver.core.exceptions.TransportException: [DNS/IP:PORT] Connection
我是Cassandra的新手,正在尝试让它在OpenShift 3.7Origin上运行。
我从DTR的一个基础镜像cassandra:3开始。我的Dockerfile文件很简单:FROM cassandra:3。在oc new-app命令执行期间,我的cassandra pod进入崩溃循环,唯一显示的日志消息是Running Cassandra as root user or group is not recommended - please start Cassandra using a different system user. If you really want to force
我使用cassandra图像创建木薯容器。我使用的卷如下:
- ./samt_tmp/cassandra_data/cassandra:/etc/cassandra/
我想要在我的pc中从码头创建cassandra.yaml,但这个路径是不存在的。
sed: can't read /etc/cassandra/cassandra.yaml: No such file or directory
可以从这个目录复制。为什么不能从目录创建卷?如何创建cassandra.yaml卷?
我在我的应用程序中使用java8和cassandra。cassandra表中current_date的数据类型是'date‘。我使用实体来映射到表值。对于同一字段,entity中的数据类型为com.datastax.driver.core.LocalDate。
当我试图检索一个记录'Select * from table where current_date='2017-06-06';'时,我得到了以下错误‘
原因:未找到请求操作的com.datastax.driver.core.exceptions.CodecNotFoundException:编解码