如何编写依赖Druid的集成测试？测试数据删除失败求助

这个问题我之前帮团队排查过类似的，Druid的删除逻辑确实和传统数据库不一样，不是简单的DELETE语句就能搞定的，你遇到的情况大概率是Kill任务没执行到位，或者Broker还缓存了旧的元数据。给你几个一步步排查和解决的方案：

• 确认Kill任务的正确性与执行状态
  首先要确保你的Kill任务参数是准确的：

  • 必须指定正确的dataSource名称
  • interval要完全覆盖测试数据的时间范围（如果不确定，可以用"1970-01-01/2030-01-01"来覆盖所有时间）
  • 任务提交后，通过Druid的API查询任务状态：

    GET /druid/indexer/v1/task/{taskId}/status
    

    只有当状态返回SUCCESS时，任务才真正完成。如果任务失败，查看Druid日志找具体原因（比如权限问题、目标Segment不存在）。

• 强制刷新Broker元数据
  即使Kill任务成功，Broker节点可能还缓存了旧的Segment元数据，导致查询依然返回已标记删除的数据。可以发送刷新请求强制Broker重新加载最新的元数据：

  POST /druid/broker/v1/metadata/refresh/{dataSource}
  

  执行完这个请求后，再尝试查询数据，应该就看不到测试数据了。

• 检查所有测试Segment是否被清理
  有时候测试可能生成了多个Segment，而你的Kill任务只覆盖了部分。可以通过Coordinator API查看该数据源下的所有Segment：

  GET /druid/coordinator/v1/metadata/datasources/{dataSource}
  

  检查返回的列表中是否还有属于测试数据的Segment，如果有，针对这些Segment单独提交Kill任务（可以指定segmentIds参数来精准删除）。

• 改用一次性测试数据源（更省心的方案）
  与其纠结删除旧数据，不如每次测试都创建一个唯一的数据源名称（比如加上测试会话ID或时间戳，例如test_report_${timestamp}）。测试结束后，直接Kill整个数据源的所有Segment：

  {
    "type": "kill",
    "dataSource": "test_report_20240520123456",
    "interval": "1970-01-01/2030-01-01",
    "context": {
      "forceKill": true
    }
  }
  

  这种方式避免了和其他数据混淆，也能确保测试数据被彻底清理。

• 排查Coordinator的Retention配置
  虽然手动Kill任务优先级高于自动Retention规则，但还是要确认Coordinator有没有配置阻止Segment删除的规则。比如如果设置了minSegmentRetentionPeriod，可能会导致Segment无法被立即删除，但这种情况比较少见，手动Kill应该能绕过该限制。

另外要注意：Kill任务只是标记Segment为待删除，Coordinator会在下次运行清理周期时删除物理文件，但这一步不影响查询——只要Segment被标记为删除，Broker就不会再返回这些数据。如果还是能查到，那肯定是前面的步骤没做对。

内容的提问来源于stack exchange，提问作者Toni Penya-Alba