Merge pull request #11241 from s1monw/readd_fail_on_recovery

[RECOVERY] Add engine failure on recovery finalization corruption back
This commit is contained in:
Simon Willnauer 2015-05-20 14:35:02 +02:00
commit 40bd56b918
1 changed files with 1 additions and 0 deletions

View File

@ -420,6 +420,7 @@ public class RecoverySourceHandler {
for (StoreFileMetaData md : metadata) {
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!
shard.engine().failEngine("recovery", corruptIndexException);
logger.warn("{} Corrupted file detected {} checksum mismatch", shard.shardId(), md);
throw corruptIndexException;
}