use a simpler API call
This commit is contained in:
parent
639515c240
commit
28f56262bc
|
@ -142,7 +142,7 @@ public class IndexingMemoryBufferController extends AbstractLifecycleComponent<I
|
||||||
// inactive?
|
// inactive?
|
||||||
if (!status.inactive) {
|
if (!status.inactive) {
|
||||||
// mark it as inactive only if enough time has passed and there are no ongoing merges going on...
|
// mark it as inactive only if enough time has passed and there are no ongoing merges going on...
|
||||||
if ((time - status.time) > inactiveTime.millis() && ((InternalIndexShard) indexShard).mergeScheduler().stats().current() == 0) {
|
if ((time - status.time) > inactiveTime.millis() && indexShard.mergeStats().current() == 0) {
|
||||||
try {
|
try {
|
||||||
((InternalIndexShard) indexShard).engine().updateIndexingBufferSize(Engine.INACTIVE_SHARD_INDEXING_BUFFER);
|
((InternalIndexShard) indexShard).engine().updateIndexingBufferSize(Engine.INACTIVE_SHARD_INDEXING_BUFFER);
|
||||||
} catch (EngineClosedException e) {
|
} catch (EngineClosedException e) {
|
||||||
|
|
Loading…
Reference in New Issue