Cassandra复合分区键查询报错：为何单symbol加price过滤需ALLOW FILTERING？

错误原因 #

直接看报错中的CQL语句：SELECT * FROM droppricealarm WHERE symbol=? AND price<=?，这个查询只指定了复合分区键的一部分（symbol），没有传入userId。你的表分区键是(symbol, userId)，Cassandra要求必须指定所有分区键列才能定位到具体的分区节点。只传symbol的话，Cassandra需要扫描所有包含该symbol的分区（每个userId对应一个独立分区），这种跨分区的全量过滤性能不可控，因此会触发该错误。

出现这种CQL的原因大概率是表名映射不匹配：你创建的表是drop_price_alarm，但实体类的@Table注解未指定表名，默认会将DropPriceAlarm转换为下划线命名的drop_price_alarm，但报错中的CQL操作的是droppricealarm（无下划线），说明Spring Data可能在操作一个自动创建的、结构不同的表（比如该自动表的分区键仅为symbol）。另外也需要检查调用Repository方法时是否漏传了userId参数。

设计推理中的问题 #

• 分区键设计思路是正确的：(symbol, userId)作为复合分区键，能让每个用户的单只股票告警数据落在独立分区，有效保证分区大小均衡，避免热点问题。
• 对查询逻辑的理解存在偏差：Cassandra的聚簇键（此处为price）的有序性和高效过滤能力，必须建立在指定完整分区键的基础上。如果未传全分区键，聚簇键的条件无法帮你精准定位数据，反而会触发全集群扫描。
• 你期望的按symbol+userId查询价格<=X的告警本身是高效合法的，但实际执行的查询偏离了这个逻辑，才导致报错。

解决步骤 #

1. 修正表名映射：在实体类的@Table注解中明确指定表名，与你创建的表保持一致：

@Table("drop_price_alarm")
public class DropPriceAlarm {
    // 原有代码不变
}

2. 确认参数传递：调用findBySymbolAndUserIdAndPriceLessThanEqual方法时，确保三个参数都正确传入，没有漏传userId。
3. 验证生成的CQL：开启Spring Data Cassandra的DEBUG日志，查看实际生成的SQL是否包含userId条件，可在配置文件中添加：

logging.level.org.springframework.data.cassandra=DEBUG

4. 若需按symbol+price查询（不指定userId）：当前表结构无法高效支持该查询，可创建物化视图：

CREATE MATERIALIZED VIEW drop_price_alarm_by_symbol_price AS
SELECT symbol, userId, price
FROM drop_price_alarm
WHERE symbol IS NOT NULL AND userId IS NOT NULL AND price IS NOT NULL
PRIMARY KEY (symbol, price, userId);

之后可基于该物化视图创建对应的Repository实现高效查询，但需注意物化视图会增加写入操作的维护成本。

内容的提问来源于stack exchange，提问作者user1796624