Parcourir la source

#647 wait for yellow status

Shinsuke Sugaya il y a 9 ans
Parent
commit
1b7ff889db
1 fichiers modifiés avec 2 ajouts et 2 suppressions
  1. 2 2
      src/main/java/org/codelibs/fess/es/client/FessEsClient.java

+ 2 - 2
src/main/java/org/codelibs/fess/es/client/FessEsClient.java

@@ -413,8 +413,8 @@ public class FessEsClient implements Client {
 
             final String updatedIndexName;
             if (isFessIndex) {
-                client.admin().indices().prepareRefresh(fessConfig.getIndexDocumentUpdateIndex()).execute()
-                        .actionGet(fessConfig.getIndexIndicesTimeout());
+                client.admin().cluster().prepareHealth(fessConfig.getIndexDocumentUpdateIndex()).setWaitForYellowStatus().execute()
+                        .actionGet();
                 final GetIndexResponse response =
                         client.admin().indices().prepareGetIndex().addIndices(fessConfig.getIndexDocumentUpdateIndex()).execute()
                                 .actionGet(fessConfig.getIndexIndicesTimeout());