问题标签 [datastax-java-driver]

Am trying to connect from Datastax java driver to cassandra secure cluster with kerberos enabled.

Sample connection code:

Am getting the below error:

Exception in thread "main" com.datastax.driver.core.exceptions.AuthenticationException: Authentication error on host /x.x.x.x: java.lang.RuntimeException: javax.security.auth.login.LoginException: Unable to obtain password from user

Am using DSE version 3.1.3. Java driver 1.0.3-dse.

我正在尝试将字节数组插入 Cassandra 表中的 Blob 数据类型。我正在使用 Datastax Java 驱动程序。下面是我的代码 -

这是我回来的例外 -

InvalidQueryException: cannot parse '[B@50908fa9' as hex bytes

我想问题是，我制作上面的 cql 的方式..肯定会丢失一些东西......

我已经创建了这样的表 -

create table test_data (user_id text, name text, value blob, primary key (user_id, name));

有谁能够帮我？谢谢...

我想知道 com.datastax.cassandra:cassandra-driver-core:2.0.0-beta2 是否可以与 org.apache.cassandra:cassandra-all:1.2.1 一起使用。我正在使用 cassandra-maven-plugin:1.2.1-1 （它使用 org.apache.cassandra:cassandra-all:1.2.1），添加

到yaml插件属性。我可以成功 telnet 到端口。

但是，当我尝试通过以下代码进行连接时，

我得到以下异常：

我认为它的症结在于Server response from unsupported protocol version: 1。

这是否意味着 2.0.0-beta2 驱动程序不能与 Cassandra 1.2.1 一起使用？驱动程序/服务器兼容性矩阵在哪里？

我已经为此烧了将近一天。

谢谢，马修

我正在使用 Datastax Java 驱动程序。有一个使用相同的教程。

我不明白的是如何关闭与 cassandra 的连接？没有可用的关闭方法，我假设我们不想关闭会话，因为它预计每个应用程序都有一个。

问候高拉夫

我正在使用 java datastax 驱动程序。我有一个 ServletContextListener，它在通过调用 Cluster.shutdown() 销毁的上下文中关闭 datastax Cluster 对象。问题是它需要 shutdown() 几分钟才能返回。

Cluster.shutdown() 有一个覆盖，您可以在其中指定超时值。我似乎找不到任何关于不使用关闭值的文档，并且当我指定一毫秒的超时时间时，集群或多或少会立即关闭（如预期的那样）。

所以，我的问题是，如果我只是在 servlet 关闭时才关闭集群，我是否有理由等待返回？似乎通过指定超时，它本质上是在调用异步关闭，这应该是可以的，但我不想引入内存泄漏或任何不稳定。

我对 Cassandra/datastax 还是很陌生，所以如果在某处说明了有关使用超时的信息，那么将我指向那个方向会很棒！

TIA, wbj

我无法使用此代码连接到 cassandra 集群。这给了我错误-

[NoHostAvailableException: All host(s) tried for query failed (tried: /192.168.1.3 ([/192.168.1.3] Cannot connect), /192.168.1.2 ([/192.168.1.2] Cannot connect))]

我在上面的代码中有什么错误。

设置：

• 2 节点 Cassandra 1.2.6 集群
• 副本=2
• 没有二级索引的非常大的 CQL3 表
• Rowkey 是一个 UUID.randomUUID().toString()
• 读取一致性设置为 ONE
• 使用 DataStax java 驱动程序 1.0

请求：

尝试通过“ SELECT some-col from schema.table LIMIT nnn; ”进行表扫描

失败：

一旦超过某个 nnn LIMIT，我就会开始从驱动程序中获取 NoHostAvailableExceptions。

它的内容如下：

鉴于：对于具有数百万行的大表，这可能不是最开明的事情，但这是我学习不该做什么的方式，所以我非常感谢能够自愿调试这种错误的人。

例如，当这种情况发生时，没有迹象表明集群中的节点曾经遇到过请求问题（任何一个节点上的日志中都没有任何内容表明任何超时或失败）。此外，我在驱动程序上启用了跟踪，只要查询成功，它就会为您提供一些很好的自动跟踪（ala Oracle）信息。但是在这种情况下，驱动程序会抛出 NoHostAvailableException 并且没有可用的 ExecutionInfo，因此在这种情况下跟踪没有提供任何好处。

我还发现有趣的是，这似乎没有被记录为超时（我的 JMX 控制台告诉我没有发生超时）。所以，我不明白故障实际发生在哪里。我的想法是驱动程序有问题，但我不知道如何调试它（我真的很想）。

我已经阅读了几篇来自人们的帖子，其中指出 query'g for resultSets > 10000 rows 可能不是一个好主意，我愿意接受这一点，但我想了解导致异常的原因以及异常发生的位置.

FWIW，我还尝试在 cassandra.yaml 中调整超时属性，但这没有任何区别。

我欢迎任何建议、轶事、侮辱或对我在白痴开发商之家注册的金钱捐助。

问候！！

我将 Cassandra Driver 2.0.0-beta2 与 Cassandra 2.0.1 一起使用。

我想在 BoundStatement 中将 NULL 值设置为“int”类型的列。我认为我不能使用 setInt。

这是我正在使用的代码：

最后一行抛出了一个空指针异常，可以解释是因为s.getSubscriberID()返回一个Integer，而BoundStatement只接受int，所以当id为null时，无法转换，因此出现异常。

在我看来，定义应该改为：

BoundStatement.setInt(String name, Integer v);

现在的方式是，我不能为数字设置 NULL 值。

还是我错过了什么？还有其他方法可以实现这一目标吗？

在 cqlsh 中，可以将 null 设置为“int”类型的列。

这是我当前的错误：

我觉得我正在导入我的 pom.xml 中我需要的所有可用的人工制品（以及许多我不想尝试解决这个问题的人工制品）。

我只是不明白为什么这不起作用？

这是我pom.xml的完整性：

有人可以让我理解为什么我会得到这个例外吗？我有一个在本地运行的 cassandra 客户端。（版本 1.2.11）。

我正在尝试编写一个简单的更新查询 - 更新表集 col1 = val1, col2 = val2 where col3 = val3; 您能否提供一个使用 Query builder API 在 Cassandra 中编写简单 UPDATE 的示例？