parent
65e42ab63b
commit
68e2d36fa3
|
@ -111,7 +111,7 @@ public class RecoverySourceHandler {
|
||||||
this.logger = Loggers.getLogger(getClass(), request.shardId(), "recover to " + request.targetNode().getName());
|
this.logger = Loggers.getLogger(getClass(), request.shardId(), "recover to " + request.targetNode().getName());
|
||||||
this.chunkSizeInBytes = fileChunkSizeInBytes;
|
this.chunkSizeInBytes = fileChunkSizeInBytes;
|
||||||
// if the target is on an old version, it won't be able to handle out-of-order file chunks.
|
// if the target is on an old version, it won't be able to handle out-of-order file chunks.
|
||||||
this.maxConcurrentFileChunks = request.targetNode().getVersion().onOrAfter(Version.V_7_0_0) ? maxConcurrentFileChunks : 1;
|
this.maxConcurrentFileChunks = request.targetNode().getVersion().onOrAfter(Version.V_6_7_0) ? maxConcurrentFileChunks : 1;
|
||||||
}
|
}
|
||||||
|
|
||||||
public StartRecoveryRequest getRequest() {
|
public StartRecoveryRequest getRequest() {
|
||||||
|
|
Loading…
Reference in New Issue