honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Adapt to RecoveryResponse change upstream 

See https://github.com/elastic/elasticsearch/pull/28878 , RecoveryResponse doesn't accept the detailed boolean flag anymore in its constructor as it was unused.

Original commit: elastic/x-pack-elasticsearch@d96df3448e
This commit is contained in:
javanna 2018-03-22 17:11:49 +01:00 committed by Luca Cavanna
parent 8296dad5ec
commit d143d26bbd
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
plugin/monitoring/src/test/java/org/elasticsearch/xpack/monitoring/collector/indices/IndexRecoveryCollectorTests.java
View File

@ -123,7 +123,7 @@ public class IndexRecoveryCollectorTests extends BaseCollectorTestCase {
recoveryStates.put("_index_" + i, singletonList(recoveryState)); recoveryStates.put("_index_" + i, singletonList(recoveryState));
} }
final RecoveryResponse recoveryResponse = final RecoveryResponse recoveryResponse =
new RecoveryResponse(randomInt(), randomInt(), randomInt(), randomBoolean(), recoveryStates, emptyList()); new RecoveryResponse(randomInt(), randomInt(), randomInt(), recoveryStates, emptyList());
final RecoveryRequestBuilder recoveryRequestBuilder = final RecoveryRequestBuilder recoveryRequestBuilder =
spy(new RecoveryRequestBuilder(mock(ElasticsearchClient.class), RecoveryAction.INSTANCE)); spy(new RecoveryRequestBuilder(mock(ElasticsearchClient.class), RecoveryAction.INSTANCE));

2
plugin/monitoring/src/test/java/org/elasticsearch/xpack/monitoring/collector/indices/IndexRecoveryMonitoringDocTests.java
View File

@ -108,7 +108,7 @@ public class IndexRecoveryMonitoringDocTests extends BaseMonitoringDocTestCase<I
final Throwable reason = new NodeDisconnectedException(discoveryNodeZero, ""); final Throwable reason = new NodeDisconnectedException(discoveryNodeZero, "");
shardFailures.add(new IndicesShardStoresResponse.Failure("_failed_node_id", "_failed_index", 1, reason)); shardFailures.add(new IndicesShardStoresResponse.Failure("_failed_node_id", "_failed_index", 1, reason));
final RecoveryResponse recoveryResponse = new RecoveryResponse(10, 7, 3, true, shardRecoveryStates, shardFailures); final RecoveryResponse recoveryResponse = new RecoveryResponse(10, 7, 3, shardRecoveryStates, shardFailures);
final MonitoringDoc.Node node = new MonitoringDoc.Node("_uuid", "_host", "_addr", "_ip", "_name", 1504169190855L); final MonitoringDoc.Node node = new MonitoringDoc.Node("_uuid", "_host", "_addr", "_ip", "_name", 1504169190855L);
final IndexRecoveryMonitoringDoc document = final IndexRecoveryMonitoringDoc document =
new IndexRecoveryMonitoringDoc("_cluster", 1502266739402L, 1506593717631L, node, recoveryResponse); new IndexRecoveryMonitoringDoc("_cluster", 1502266739402L, 1506593717631L, node, recoveryResponse);