[RECOVERY] Add engine failure on recovery finalization corruption back
This engine failure on finalization corruption was lost on refactorings and should be added back.
This commit is contained in:
parent
eaa8576bba
commit
8949cb85fb
|
@ -420,6 +420,7 @@ public class RecoverySourceHandler {
|
||||||
for (StoreFileMetaData md : metadata) {
|
for (StoreFileMetaData md : metadata) {
|
||||||
logger.debug("{} checking integrity for file {} after remove corruption exception", shard.shardId(), md);
|
logger.debug("{} checking integrity for file {} after remove corruption exception", shard.shardId(), md);
|
||||||
if (store.checkIntegrityNoException(md) == false) { // we are corrupted on the primary -- fail!
|
if (store.checkIntegrityNoException(md) == false) { // we are corrupted on the primary -- fail!
|
||||||
|
shard.engine().failEngine("recovery", corruptIndexException);
|
||||||
logger.warn("{} Corrupted file detected {} checksum mismatch", shard.shardId(), md);
|
logger.warn("{} Corrupted file detected {} checksum mismatch", shard.shardId(), md);
|
||||||
throw corruptIndexException;
|
throw corruptIndexException;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue