add wait_for_completion,refresh to updateByQuery

fly-studio · Sep 4, 2018 · 649c791 · 649c791
1 parent 54fc016
commit 649c791
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/main/java/com/fly/sync/es/Writer.java b/src/main/java/com/fly/sync/es/Writer.java
@@ -43,6 +43,8 @@ public void updateByQuery(AbstractRelateAction relateAction)
         River.Table table = dbFactory.getRiverDatabase().getTable(associate.calledTable.tableName);
         Map<String, String> params = new HashMap<>();
         params.put("conflicts", "proceed");
+        params.put("refresh", "false");
+        params.put("wait_for_completion", "false");
 
         int offset = associate.findOffset(record.table);
         // == 0 is a sync-table, not a relation