From 61b7f49ed25b483a10dff5a56f7cbb992342e200 Mon Sep 17 00:00:00 2001 From: Boaz Leskes Date: Sat, 18 Jun 2016 19:13:50 +0200 Subject: [PATCH] ESIndexLevelReplicationTestCase.java fix line lengths --- .../index/replication/ESIndexLevelReplicationTestCase.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/core/src/test/java/org/elasticsearch/index/replication/ESIndexLevelReplicationTestCase.java b/core/src/test/java/org/elasticsearch/index/replication/ESIndexLevelReplicationTestCase.java index 7ccf0a3e642..924469ca6cb 100644 --- a/core/src/test/java/org/elasticsearch/index/replication/ESIndexLevelReplicationTestCase.java +++ b/core/src/test/java/org/elasticsearch/index/replication/ESIndexLevelReplicationTestCase.java @@ -132,7 +132,8 @@ public class ESIndexLevelReplicationTestCase extends ESTestCase { IndexShard replica = shards.addReplica(); final CountDownLatch recoveryBlocked = new CountDownLatch(1); final CountDownLatch releaseRecovery = new CountDownLatch(1); - final Future recoveryFuture = shards.asyncRecoverReplica(replica, new BiFunction() { + final Future recoveryFuture = shards.asyncRecoverReplica(replica, + new BiFunction() { @Override public RecoveryTarget apply(IndexShard indexShard, DiscoveryNode node) { return new RecoveryTarget(indexShard, node, recoveryListener) { @@ -441,7 +442,8 @@ public class ESIndexLevelReplicationTestCase extends ESTestCase { } @Override - public void failShard(ShardRouting replica, ShardRouting primary, String message, Throwable throwable, Runnable onSuccess, Consumer onPrimaryDemoted, Consumer onIgnoredFailure) { + public void failShard(ShardRouting replica, ShardRouting primary, String message, Throwable throwable, Runnable onSuccess, + Consumer onPrimaryDemoted, Consumer onIgnoredFailure) { throw new UnsupportedOperationException(); } }