honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-02-26 06:46:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fire off another maybeFlush on finish to ensure we don't miss a pending flush

Browse Source
This commit is contained in:
Simon Willnauer 2015-09-24 09:28:14 +02:00
parent 1fd8c64f1f
commit 6cbf2de592
2 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1521,6 +1521,7 @@ public class IndexShard extends AbstractIndexShardComponent {
@Override
public void onAfter() {
asyncFlushRunning.compareAndSet(true, false);
maybeFlush(); // fire a flush up again if we have filled up the limits such that shouldFlush() returns true
}
};
threadPool.executor(ThreadPool.Names.FLUSH).execute(abstractRunnable);
@ -1530,5 +1531,4 @@ public class IndexShard extends AbstractIndexShardComponent {
}
return false;
}
}

1
core/src/test/java/org/elasticsearch/index/shard/IndexShardTests.java
View File

@ -690,7 +690,6 @@ public class IndexShardTests extends ESSingleNodeTestCase {
assertTrue(postIndexWithExceptionCalled.get());
}
public void testMaybeFlush() throws Exception {
createIndex("test", settingsBuilder().put(TranslogConfig.INDEX_TRANSLOG_DURABILITY, Translog.Durabilty.REQUEST).build());
ensureGreen();