Skip to content

Commit 16eb9ad

Browse files
committed
Revert "Make peer recovery send file chunks async (#44040)"
This reverts commit 30b7545.
1 parent ca9ee21 commit 16eb9ad

File tree

7 files changed

+182
-384
lines changed

7 files changed

+182
-384
lines changed

server/src/main/java/org/elasticsearch/indices/recovery/MultiFileTransfer.java

Lines changed: 0 additions & 210 deletions
This file was deleted.

server/src/main/java/org/elasticsearch/indices/recovery/PeerRecoverySourceService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -176,7 +176,7 @@ private RecoverySourceHandler createRecoverySourceHandler(StartRecoveryRequest r
176176
final RemoteRecoveryTargetHandler recoveryTarget =
177177
new RemoteRecoveryTargetHandler(request.recoveryId(), request.shardId(), transportService,
178178
request.targetNode(), recoverySettings, throttleTime -> shard.recoveryStats().addThrottleTime(throttleTime));
179-
handler = new RecoverySourceHandler(shard, recoveryTarget, shard.getThreadPool(), request,
179+
handler = new RecoverySourceHandler(shard, recoveryTarget, request,
180180
Math.toIntExact(recoverySettings.getChunkSize().getBytes()), recoverySettings.getMaxConcurrentFileChunks());
181181
return handler;
182182
}

0 commit comments

Comments
 (0)