问题标签 [spring-data-cassandra]

我将 app1.war 和 app2.war 部署在同一个 tomcat jvm 中。两个应用程序都有自己的上下文 xml - app1.xml 和 app2.xml。这两个应用程序都包含连接到 Cassandra 的 datastax 驱动程序依赖项。它们在单独部署时运行良好。但是当两者都部署在同一个 jvm 中时，我在日志中看到以下 JMX 异常：

该应用程序可以正常工作。我只是担心为什么会看到此错误以及如何避免此错误。

一旦 cassandra 在其中一个节点上开始压缩，我们就会看到我们的应用程序无法连接到该节点。我注意到的是，当在其中一个节点中开始压缩时，该节点的 CPU 负载变为 100%，并且随着压缩的进行和 cpu 负载变低，我们的应用程序能够连接回 cassandra。

我们使用 m3.xlarge Amazon EC2 实例在同一个节点上运行我们的 java 应用程序和 cassandra。我们的应用程序和 cassandra 都有以下 jvm 设置 -Xms2G -Xmx2G -Xmn512M。Cassandra 几乎没有 300MB 的数据，但我们仍然看到如此多的压缩发生。这是我们的 cassandra 列族设置之一的样子，我们有大约 20 个具有几乎相同设置的列族。每个列族都有一个二级索引。

我们正在运行 cassandra 社区版本 2.0.5 和数据映射库https://github.com/valchkou/cassandra-driver-mapping。

我环顾四周，没有看到任何人面临这种​​问题。任何帮助将不胜感激。

错误堆栈跟踪

嘿，我是 Cassandra 的新手，我对 Spring jdbc-template 很友好。

谁能解释一下它们之间的区别？另外你能建议哪一个好用吗？

谢谢。

Heyy你好，我有一些不会影响我的项目的编译，部署和运行的错误但是它在我的Spring-data-Cassandra配置文件中显示红色标记也显示问题菜单中的问题。 任何人都可以请告诉什么问题？

我看到了与 spring-data-JPA 和 Spring-data-* 相关的相同问题，但它们没有帮助，所以我发布了这个。

这是错误消息：-

1. 通过文件“application-config.xml”验证文件“spring-tool.xsd”时检测到以下错误。在大多数情况下，可以通过直接验证“spring-tool.xsd”来检测这些错误。但是，只有在 application-config.xml 的上下文中验证 spring-tool.xsd 时才会发生错误。
2. 通过文件“application-config.xml”验证文件“spring-beans.xsd”时检测到以下错误。在大多数情况下，这些错误可以通过直接验证“spring-beans.xsd”来检测。但是，只有在 application-config.xml 的上下文中验证 spring-beans.xsd 时才会发生错误。

这是我的 config.xml 文件和 pom 文件

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:cassandra="http://www.springframework.org/schema/data/cassandra" xmlns:tx="http://www.springframework.org/schema/tx"

</beans>

POM 文件

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>org.springframework.samples.service.service</groupId> <artifactId>XYZ</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>war</packaging>

</project>

我是 Spark/Spark Cassandra 连接器的新手。我们在团队中第一次尝试使用 spark，我们正在使用 spark cassandra 连接器连接到 cassandra 数据库。

我写了一个查询，该查询使用了一个沉重的数据库表，我看到 Spark Task 直到对表的查询获取所有记录后才开始。

仅从数据库中获取所有记录就需要 3 个多小时。

从我们使用的数据库中获取数据。

即使所有数据都没有完成下载，有没有办法告诉 spark 开始工作？

是否可以选择告诉 spark-cassandra-connector 使用更多线程进行 fetch ？

谢谢，kokou。

我正在使用 spring-data-cassandra 1.1.2.RELEASE 通过 spring 数据存储库将对象从 Cassandra DB 映射到 Cassandra DB。我有一个特殊要求，即密码类属性必须在数据库中加密，并且在从数据库加载数据时必须解密。

我们在使用 spring-data-mongo 并添加自定义事件侦听器之前已经完成了这项工作AbstractMongoEventListener，我们使用 jasypt 在对象被读/写到数据库之前和之后进行加密/解密。

我们一直在尝试为 Cassandra 使用一些事件侦听器（如果存在）。与此同时，我们发现一个可能的解决方案是使用自定义转换器，但是这方面的文档很少（文档中的 5.8.1 - 5.8.9 部分是空的http://docs.spring.io/spring -data/cassandra/docs/current/reference/html/#cassandra.custom-converters）。

我的问题是，这是最好和最干净的方法吗？我在哪里可以找到有关如何实现这一目标的示例和文档？...

是否可以在 cassandra 中进行顺序批处理。例如：插入 table1 并从此插入操作中获取 uuid 并将其传递给 table2 插入语句。如果表 2 插入失败，则整个操作失败。

如果没有，我最好的选择是什么？

（它的交易类型）

任何人都可以帮忙吗？

我需要知道如何在使用 spring 数据 cassandra 时使用 IN 运算符更新 @Query？

因为我想使用这样的东西：@Query("UPDATE objects SET children = ?0 WHERE id IN (?...)")

如果可能的话。可能我应该对这种查询使用本机数据 stax 模板。

提前谢谢

我有一个 spring-boot 应用程序，我正在尝试使用 spring-data-cassandra 连接到 cassandra 数据库。以下是我的文件。

SampleApp.java

CassandraDataSourceConfig.java

属性文件

以下是我尝试使用嵌入式 tomcat 服务器（mvn spring-boot:run）启动应用程序时遇到的异常。该应用程序无法加载抱怨无法自动装配字段：私有 javax.sql.DataSource。但是，我显然在主应用程序文件（SampleApp.java）中导入了 CassandraDataSourceConfig.java。有人可以帮忙吗？为什么应用程序无法将 CassandraDataSourceConfig.java 识别为有效数据源。？我是否必须为将 spring-data-cassandra 与 spring-boot 集成做一些特别的事情？？提前致谢。！！

更新 我的项目依赖于 spring-data-cassandra 和 spring-boot-starter-jpa。当我删除对 spring-boot-started-jpa 的依赖时，一切正常。应用程序启动，我能够从 cassandra 集群进行读写。

我可以使用 Spring 数据 cassandra 创建表，其配置文件通过覆盖函数扩展 AbstractCassandraConfiguration

但它通过首先删除键空间中的所有表然后创建表来创建表。在此过程中，我丢失了表中的现有数据。我想实现类似 SchemaSync：https ://github.com/valchkou/cassandra-driver-mapping/blob/master/src/main/java/com/datastax/driver/mapping/schemasync/SchemaSync.java

这样，每当我的列族模式发生变化时，例如添加新列，表就会用新列更新，而不会删除表中的现有条目。