|
@@ -271,7 +271,7 @@ public class GatewayAllocator implements ExistingShardsAllocator {
|
|
|
|
|
|
@Override
|
|
|
protected AsyncShardFetch.FetchResult<NodeStoreFilesMetadata> fetchData(ShardRouting shard, RoutingAllocation allocation) {
|
|
|
- // explicitely type lister, some IDEs (Eclipse) are not able to correctly infer the function type
|
|
|
+ // explicitly type lister, some IDEs (Eclipse) are not able to correctly infer the function type
|
|
|
Lister<BaseNodesResponse<NodeStoreFilesMetadata>, NodeStoreFilesMetadata> lister = this::listStoreFilesMetadata;
|
|
|
AsyncShardFetch<NodeStoreFilesMetadata> fetch = asyncFetchStore.computeIfAbsent(shard.shardId(),
|
|
|
shardId -> new InternalAsyncFetch<>(logger, "shard_store", shard.shardId(),
|