add refresh=wait_until when create metalog

Signed-off-by: Peng Huo <[email protected]>
opensearch-project · Nov 21, 2023 · a0a251d · a0a251d
1 parent 6055e1a
commit a0a251d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/flint-core/src/main/scala/org/opensearch/flint/core/storage/FlintOpenSearchMetadataLog.java b/flint-core/src/main/scala/org/opensearch/flint/core/storage/FlintOpenSearchMetadataLog.java
@@ -116,6 +116,7 @@ private FlintMetadataLogEntry createLogEntry(FlintMetadataLogEntry logEntry) {
             new IndexRequest()
                 .index(metaLogIndexName)
                 .id(logEntryWithId.id())
+                .setRefreshPolicy(RefreshPolicy.WAIT_UNTIL)
                 .source(logEntryWithId.toJson(), XContentType.JSON),
             RequestOptions.DEFAULT));
   }