浏览代码

fixed delete

zero 1 年之前
父节点
当前提交
b9cfb1f51e
共有 1 个文件被更改,包括 2 次插入1 次删除
  1. 2 1
      src/main/java/cn/cslg/pas/service/business/es/EsService.java

+ 2 - 1
src/main/java/cn/cslg/pas/service/business/es/EsService.java

@@ -1451,7 +1451,8 @@ public class EsService {
 
 
     public Integer deleteByIds(List<String> ids) {
     public Integer deleteByIds(List<String> ids) {
         Query query = QueryBuilders.ids(n -> n.values(ids));
         Query query = QueryBuilders.ids(n -> n.values(ids));
-        DeleteByQueryRequest request = DeleteByQueryRequest.of(i -> i.index("patent").query(query).refresh(true));
+        DeleteByQueryRequest request = DeleteByQueryRequest.of(i -> i.index("patent").query(query)
+                .refresh(true).waitForActiveShards(j -> j.count(3)));
         try {
         try {
             client.deleteByQuery(request);
             client.deleteByQuery(request);
             return 1;
             return 1;