ignore failure to flush when the engine is closed and updating its settings
This commit is contained in:
parent
eb057d4ce6
commit
a77e5757c8
|
@ -212,6 +212,10 @@ public class RobinEngine extends AbstractIndexShardComponent implements Engine {
|
||||||
if (indexingBufferSize == Engine.INACTIVE_SHARD_INDEXING_BUFFER && preValue != Engine.INACTIVE_SHARD_INDEXING_BUFFER) {
|
if (indexingBufferSize == Engine.INACTIVE_SHARD_INDEXING_BUFFER && preValue != Engine.INACTIVE_SHARD_INDEXING_BUFFER) {
|
||||||
try {
|
try {
|
||||||
flush(new Flush().full(true));
|
flush(new Flush().full(true));
|
||||||
|
} catch (EngineClosedException e) {
|
||||||
|
// ignore
|
||||||
|
} catch (FlushNotAllowedEngineException e) {
|
||||||
|
// ignore
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
logger.warn("failed to flush after setting shard to inactive", e);
|
logger.warn("failed to flush after setting shard to inactive", e);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue