honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-02-17 18:35:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

ESIndexLevelReplicationTestCase.java fix line lengths

Browse Source
This commit is contained in:
Boaz Leskes 2016-06-18 19:13:50 +02:00
parent 14cd8a6794
commit 61b7f49ed2
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
core/src/test/java/org/elasticsearch/index/replication/ESIndexLevelReplicationTestCase.java
View File

@ -132,7 +132,8 @@ public class ESIndexLevelReplicationTestCase extends ESTestCase {
IndexShard replica = shards.addReplica(); IndexShard replica = shards.addReplica();
final CountDownLatch recoveryBlocked = new CountDownLatch(1); final CountDownLatch recoveryBlocked = new CountDownLatch(1);
final CountDownLatch releaseRecovery = new CountDownLatch(1); final CountDownLatch releaseRecovery = new CountDownLatch(1);
final Future<Void> recoveryFuture = shards.asyncRecoverReplica(replica, new BiFunction<IndexShard, DiscoveryNode, RecoveryTarget>() { final Future<Void> recoveryFuture = shards.asyncRecoverReplica(replica,
new BiFunction<IndexShard, DiscoveryNode, RecoveryTarget>() {
@Override @Override
public RecoveryTarget apply(IndexShard indexShard, DiscoveryNode node) { public RecoveryTarget apply(IndexShard indexShard, DiscoveryNode node) {
return new RecoveryTarget(indexShard, node, recoveryListener) { return new RecoveryTarget(indexShard, node, recoveryListener) {
@ -441,7 +442,8 @@ public class ESIndexLevelReplicationTestCase extends ESTestCase {
} }
@Override @Override
public void failShard(ShardRouting replica, ShardRouting primary, String message, Throwable throwable, Runnable onSuccess, Consumer<Throwable> onPrimaryDemoted, Consumer<Throwable> onIgnoredFailure) { public void failShard(ShardRouting replica, ShardRouting primary, String message, Throwable throwable, Runnable onSuccess,
Consumer<Throwable> onPrimaryDemoted, Consumer<Throwable> onIgnoredFailure) {
throw new UnsupportedOperationException(); throw new UnsupportedOperationException();
} }
} }