Jelajahi Sumber

fix: es index

许家凯 3 tahun lalu
induk
melakukan
0a4f46cfbd

+ 1 - 1
src/main/java/com/winhc/bigdata/task/jobs/DynamicPersonIdUpdateJob.java

@@ -154,7 +154,7 @@ public class DynamicPersonIdUpdateJob {
 
         return CompletableFuture.runAsync(() -> {
             try {
-                String s = restClient.updateByQuery("winhc-company-dynamic_inc_v1/_update_by_query?conflicts=proceed", createUpdate);
+                String s = restClient.updateByQuery("winhc-company-dynamic/_update_by_query?conflicts=proceed", createUpdate);
                 if (s.contains("version_conflicts") && s.contains("\"version_conflicts\": 0")) {
                     //do something
                 } else {