Skip to content

Commit 6791827

Browse files
committed
Fix imports
1 parent 0ac5533 commit 6791827

File tree

1 file changed

+10
-4
lines changed

1 file changed

+10
-4
lines changed

x-pack/plugin/ccr/src/test/java/org/elasticsearch/xpack/ccr/IndexFollowingIT.java

Lines changed: 10 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1009,10 +1009,16 @@ public void testIndexFallBehind() throws Exception {
10091009
.getState()
10101010
.routingTable();
10111011

1012-
final String retentionLeaseId =
1013-
retentionLeaseId(getFollowerCluster().getClusterName(), getLeaderCluster().getClusterName(), "index2", followerUUID, "index1", leaderUUID);
1014-
1015-
for (ObjectCursor<IndexShardRoutingTable> shardRoutingTable : leaderRoutingTable.index("index1").shards().values()) {
1012+
final String retentionLeaseId = retentionLeaseId(
1013+
getFollowerCluster().getClusterName(),
1014+
getLeaderCluster().getClusterName(),
1015+
"index2",
1016+
followerUUID,
1017+
"index1",
1018+
leaderUUID);
1019+
1020+
for (final ObjectCursor<IndexShardRoutingTable> shardRoutingTable
1021+
: leaderRoutingTable.index("index1").shards().values()) {
10161022
final ShardId shardId = shardRoutingTable.value.shardId();
10171023
leaderClient().execute(
10181024
RetentionLeaseActions.Remove.INSTANCE,

0 commit comments

Comments
 (0)