honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

push settings change before refresh, when shard becomes inactive

This commit is contained in:
Michael McCandless 2015-09-14 05:18:07 -04:00 committed by mikemccand
parent 9148382be0
commit 274044e7dd
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
core/src/main/java/org/elasticsearch/index/shard/IndexShard.java
View File

@ -996,6 +996,9 @@ public class IndexShard extends AbstractIndexShardComponent {
// update engine if it is already started. // update engine if it is already started.
if (preValue.bytes() != shardIndexingBufferSize.bytes()) { if (preValue.bytes() != shardIndexingBufferSize.bytes()) {
// so we push changes these changes down to IndexWriter:
engine.onSettingsChanged();
if (shardIndexingBufferSize == EngineConfig.INACTIVE_SHARD_INDEXING_BUFFER) { if (shardIndexingBufferSize == EngineConfig.INACTIVE_SHARD_INDEXING_BUFFER) {
// it's inactive: make sure we do a refresh / full IW flush in this case, since the memory // it's inactive: make sure we do a refresh / full IW flush in this case, since the memory
// changes only after a "data" change has happened to the writer // changes only after a "data" change has happened to the writer
@ -1009,9 +1012,6 @@ public class IndexShard extends AbstractIndexShardComponent {
} else { } else {
logger.debug("updating index_buffer_size from [{}] to [{}]", preValue, shardIndexingBufferSize); logger.debug("updating index_buffer_size from [{}] to [{}]", preValue, shardIndexingBufferSize);
} }
// so we push changes these changes down to IndexWriter:
engine.onSettingsChanged();
} }
engine.getTranslog().updateBuffer(shardTranslogBufferSize); engine.getTranslog().updateBuffer(shardTranslogBufferSize);