joerg/elx
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix wait for active shards

Browse source
This commit is contained in:
Jörg Prante 2019-02-23 15:26:36 +01:00
parent 41b18f4ae7
commit 37b664f1b6
1 changed files with 5 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
elx-common/src/main/java/org/xbib/elx/common/AbstractExtendedClient.java
View file

@ -438,14 +438,11 @@ public abstract class AbstractExtendedClient implements ExtendedClient {
public boolean waitForRecovery(String index, long maxWaitTime, TimeUnit timeUnit) { public boolean waitForRecovery(String index, long maxWaitTime, TimeUnit timeUnit) {
ensureActive(); ensureActive();
ensureIndexGiven(index); ensureIndexGiven(index);
RecoveryRequest recoveryRequest = new RecoveryRequest(); GetSettingsRequest settingsRequest = new GetSettingsRequest();
recoveryRequest.indices(index); settingsRequest.indices(index);
recoveryRequest.activeOnly(true); GetSettingsResponse settingsResponse = client.execute(GetSettingsAction.INSTANCE, settingsRequest).actionGet();
RecoveryResponse recoveryResponse = client.execute(RecoveryAction.INSTANCE, recoveryRequest).actionGet(); int shards = settingsResponse.getIndexToSettings().get(index).getAsInt("index.number_of_shards", -1);
if (recoveryResponse.hasRecoveries()) { if (shards > 0) {
int shards = recoveryResponse.getTotalShards();
logger.info("shards = {}", shards);
logger.info(recoveryResponse.shardRecoveryStates());
TimeValue timeout = toTimeValue(maxWaitTime, timeUnit); TimeValue timeout = toTimeValue(maxWaitTime, timeUnit);
ClusterHealthRequest clusterHealthRequest = new ClusterHealthRequest() ClusterHealthRequest clusterHealthRequest = new ClusterHealthRequest()
.indices(new String[]{index}) .indices(new String[]{index})