单节点Cassandra（Windows Docker环境）删除操作无法立即生效问题咨询

环境信息 #

• 运行环境：Windows系统Docker容器内的单节点Cassandra；Linux环境下无此问题
• 客户端：使用Datastax Java驱动连接

测试流程 #

1. 向my_lock_table表插入一行数据
2. 修改Schema（同一keyspace下创建额外表，耗时约300ms）
3. 通过分区键删除my_lock_table表中的该行数据
4. 通过分区键查询my_lock_table表：Linux环境下无结果（符合预期），Windows环境下仍返回已删除的行

已做排查 #

1. 为删除语句添加IF EXISTS子句后，删除操作可立即生效，数据被移除
2. 多次执行普通删除语句无效，需等待插入操作完成10秒后再次执行删除，数据才会被移除
3. 查看Cassandra日志，所有查询的时间戳顺序正常

可能原因与解决方向 #

1. Windows Docker时间同步偏差 #

Windows Docker容器与宿主机的时间同步容易出问题，Cassandra依赖时间戳处理读写冲突。虽然日志显示时间戳顺序正常，但容器内系统时间和客户端（宿主机Java应用）可能存在微小偏移，导致删除操作的时间戳没覆盖插入的时间戳。

• 处理方式：在容器内执行date命令，和宿主机时间对比；若不一致，重启Docker服务，或WSL2环境下执行wsl --shutdown重启子系统。

2. 读一致性与存储缓存延迟 #

单节点环境下默认读一致性级别ONE理论上能读到最新数据，但Windows Docker的存储层（比如WSL2文件系统）可能存在缓存延迟，导致读取旧数据。

• 处理方式：将读一致性级别调整为LOCAL_QUORUM（单节点下效果等同于ONE，但强制读取本地节点最新数据），或在查询时显式指定一致性级别：

  Select selectQuery = Select.from("my_lock_table").where(QueryBuilder.eq("partition_key", key));
  selectQuery.setConsistencyLevel(ConsistencyLevel.LOCAL_QUORUM);
  ResultSet result = session.execute(selectQuery);
  

3. 删除语句时间戳机制问题 #

普通删除语句默认用客户端驱动生成的时间戳，Schema变更期间可能导致驱动生成的时间戳异常，而IF EXISTS子句会强制Cassandra用服务器端时间戳覆盖旧数据。

• 处理方式：
  • 显式指定删除语句的时间戳，确保晚于插入操作的时间戳：

    Delete deleteQuery = Delete.allFrom("my_lock_table").where(QueryBuilder.eq("partition_key", key));
    // 转换为Cassandra使用的微秒级时间戳
    deleteQuery.setTimestamp(System.currentTimeMillis() * 1000);
    session.execute(deleteQuery);
    

  • 直接使用带IF EXISTS的删除语句，虽然有轻微性能开销，但能确保删除生效：

    Delete deleteQuery = Delete.allFrom("my_lock_table")
      .where(QueryBuilder.eq("partition_key", key))
      .ifExists();
    session.execute(deleteQuery);
    

4. Windows Docker存储性能瓶颈 #

WSL2文件系统处理Cassandra的SSTable读写时可能有延迟，导致删除产生的墓碑（tombstone）未及时被应用，10秒等待时间刚好接近内存缓存的刷新周期。

• 处理方式：
  • 调整Cassandra配置文件中的memtable_flush_period_in_ms参数，缩短内存表刷新到磁盘的时间；
  • 确保Docker使用WSL2 backend而非Hyper-V，并将存储驱动设置为overlay2，提升存储读写性能。

内容的提问来源于stack exchange，提问作者Adam Wołek