Adjust bwc version for max_concurrent_file_chunks

dnhatn · dnhatn · commit 68e2d36fa301 · 2019-01-15T11:18:55.000-05:00
Relates #36981
diff --git a/server/src/main/java/org/elasticsearch/indices/recovery/RecoverySourceHandler.java b/server/src/main/java/org/elasticsearch/indices/recovery/RecoverySourceHandler.java
@@ -111,7 +111,7 @@ public RecoverySourceHandler(final IndexShard shard, RecoveryTargetHandler recov
         this.logger = Loggers.getLogger(getClass(), request.shardId(), "recover to " + request.targetNode().getName());
         this.chunkSizeInBytes = fileChunkSizeInBytes;
         // 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() {

Original file line number	Diff line number	Diff line change
`@@ -111,7 +111,7 @@ public RecoverySourceHandler(final IndexShard shard, RecoveryTargetHandler recov`
`111`	`111`	`this.logger = Loggers.getLogger(getClass(), request.shardId(), "recover to " + request.targetNode().getName());`
`112`	`112`	`this.chunkSizeInBytes = fileChunkSizeInBytes;`
`113`	`113`	`// if the target is on an old version, it won't be able to handle out-of-order file chunks.`
`114`		`- this.maxConcurrentFileChunks = request.targetNode().getVersion().onOrAfter(Version.V_7_0_0) ? maxConcurrentFileChunks : 1;`
	`114`	`+ this.maxConcurrentFileChunks = request.targetNode().getVersion().onOrAfter(Version.V_6_7_0) ? maxConcurrentFileChunks : 1;`
`115`	`115`	`}`
`116`	`116`
`117`	`117`	`public StartRecoveryRequest getRequest() {`