From 36be13ffb30030d2b8309d6ae6ded16303a87b0a Mon Sep 17 00:00:00 2001 From: kimchy Date: Wed, 15 Dec 2010 01:28:21 +0200 Subject: [PATCH] bring back the file chunk size in recovery to 100kb from 500kb --- .../org/elasticsearch/index/shard/recovery/RecoverySource.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/index/shard/recovery/RecoverySource.java b/modules/elasticsearch/src/main/java/org/elasticsearch/index/shard/recovery/RecoverySource.java index 61083791be6..0dc990a2552 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/index/shard/recovery/RecoverySource.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/index/shard/recovery/RecoverySource.java @@ -87,7 +87,7 @@ public class RecoverySource extends AbstractComponent { int concurrentStreams = componentSettings.getAsInt("concurrent_streams", 5); this.concurrentStreamPool = DynamicExecutors.newScalingThreadPool(1, concurrentStreams, TimeValue.timeValueSeconds(5).millis(), EsExecutors.daemonThreadFactory(settings, "[recovery_stream]")); - this.fileChunkSize = componentSettings.getAsBytesSize("file_chunk_size", new ByteSizeValue(500, ByteSizeUnit.KB)); + this.fileChunkSize = componentSettings.getAsBytesSize("file_chunk_size", new ByteSizeValue(100, ByteSizeUnit.KB)); this.translogBatchSize = componentSettings.getAsInt("translog_batch_size", 100); this.compress = componentSettings.getAsBoolean("compress", true);