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

fix check on which settings to change on

This commit is contained in:
Shay Banon 2013-02-16 23:26:58 +01:00 committed by Igor Motov
parent 73a447da86
commit e365ecce10
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/org/elasticsearch/index/engine/robin/RobinEngine.java
View File

@ -1352,7 +1352,7 @@ public class RobinEngine extends AbstractIndexShardComponent implements Engine {
int indexConcurrency = settings.getAsInt("index.index_concurrency", RobinEngine.this.indexConcurrency); int indexConcurrency = settings.getAsInt("index.index_concurrency", RobinEngine.this.indexConcurrency);
String codecName = settings.get("index.codec", RobinEngine.this.codecName); String codecName = settings.get("index.codec", RobinEngine.this.codecName);
boolean requiresFlushing = false; boolean requiresFlushing = false;
if (termIndexInterval != RobinEngine.this.termIndexInterval || termIndexDivisor != RobinEngine.this.termIndexDivisor) { if (termIndexInterval != RobinEngine.this.termIndexInterval || termIndexDivisor != RobinEngine.this.termIndexDivisor || indexConcurrency != RobinEngine.this.indexConcurrency || !codecName.equals(RobinEngine.this.codecName)) {
rwl.readLock().lock(); rwl.readLock().lock();
try { try {
if (termIndexInterval != RobinEngine.this.termIndexInterval) { if (termIndexInterval != RobinEngine.this.termIndexInterval) {
@ -1376,7 +1376,7 @@ public class RobinEngine extends AbstractIndexShardComponent implements Engine {
if (!codecName.equals(RobinEngine.this.codecName)) { if (!codecName.equals(RobinEngine.this.codecName)) {
logger.info("updating index.codec from [{}] to [{}]", RobinEngine.this.codecName, codecName); logger.info("updating index.codec from [{}] to [{}]", RobinEngine.this.codecName, codecName);
RobinEngine.this.codecName = codecName; RobinEngine.this.codecName = codecName;
// TODO: Lucene 4, I think once someones changes codec, it should be reflected immediately // we want to flush in this case, so the new codec will be reflected right away...
requiresFlushing = true; requiresFlushing = true;
} }
} finally { } finally {