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

Fix LineLength issues.

This commit is contained in:
Adrien Grand 2016-12-26 11:22:09 +01:00
parent d89757b848
commit f80165c374
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/action/support/replication/ReplicationResponseTests.java
View File

@ -84,7 +84,8 @@ public class ReplicationResponseTests extends ESTestCase {
List<Supplier<ReplicationResponse.ShardInfo.Failure>> mutations = new ArrayList<>(); List<Supplier<ReplicationResponse.ShardInfo.Failure>> mutations = new ArrayList<>();
final Index index = failure.fullShardId().getIndex(); final Index index = failure.fullShardId().getIndex();
final Set<String> indexNamePool = new HashSet<>(Arrays.asList(randomUnicodeOfCodepointLength(5), randomUnicodeOfCodepointLength(6))); final Set<String> indexNamePool = new HashSet<>(Arrays.asList(
randomUnicodeOfCodepointLength(5), randomUnicodeOfCodepointLength(6)));
indexNamePool.remove(index.getName()); indexNamePool.remove(index.getName());
final ShardId randomIndex = new ShardId(randomFrom(indexNamePool), index.getUUID(), failure.shardId()); final ShardId randomIndex = new ShardId(randomFrom(indexNamePool), index.getUUID(), failure.shardId());
mutations.add(() -> new ReplicationResponse.ShardInfo.Failure(randomIndex, failure.nodeId(), (Exception) failure.getCause(), mutations.add(() -> new ReplicationResponse.ShardInfo.Failure(randomIndex, failure.nodeId(), (Exception) failure.getCause(),
@ -106,7 +107,8 @@ public class ReplicationResponseTests extends ESTestCase {
mutations.add(() -> new ReplicationResponse.ShardInfo.Failure(failure.fullShardId(), randomNode, (Exception) failure.getCause(), mutations.add(() -> new ReplicationResponse.ShardInfo.Failure(failure.fullShardId(), randomNode, (Exception) failure.getCause(),
failure.status(), failure.primary())); failure.status(), failure.primary()));
final Set<Exception> exceptionPool = new HashSet<>(Arrays.asList(new IllegalStateException("a"), new IllegalArgumentException("b"))); final Set<Exception> exceptionPool = new HashSet<>(Arrays.asList(
new IllegalStateException("a"), new IllegalArgumentException("b")));
exceptionPool.remove(failure.getCause()); exceptionPool.remove(failure.getCause());
final Exception randomException = randomFrom(exceptionPool); final Exception randomException = randomFrom(exceptionPool);
mutations.add(() -> new ReplicationResponse.ShardInfo.Failure(failure.fullShardId(), failure.nodeId(), randomException, mutations.add(() -> new ReplicationResponse.ShardInfo.Failure(failure.fullShardId(), failure.nodeId(), randomException,