honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fail engine if metadata is corrupted on recovery start

This commit is contained in:
Simon Willnauer 2015-05-04 12:18:22 +02:00
parent 7e5f9d5628
commit bbffca193c
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/org/elasticsearch/indices/recovery/RecoverySourceHandler.java
View File

@ -22,6 +22,8 @@ package org.elasticsearch.indices.recovery;
import com.google.common.collect.Iterables; import com.google.common.collect.Iterables;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
import org.apache.lucene.index.CorruptIndexException; import org.apache.lucene.index.CorruptIndexException;
import org.apache.lucene.index.IndexFormatTooNewException;
import org.apache.lucene.index.IndexFormatTooOldException;
import org.apache.lucene.store.IOContext; import org.apache.lucene.store.IOContext;
import org.apache.lucene.store.IndexInput; import org.apache.lucene.store.IndexInput;
import org.apache.lucene.store.RateLimiter; import org.apache.lucene.store.RateLimiter;
@ -178,7 +180,13 @@ public class RecoverySourceHandler {
store.incRef(); store.incRef();
try { try {
StopWatch stopWatch = new StopWatch().start(); StopWatch stopWatch = new StopWatch().start();
final Store.MetadataSnapshot recoverySourceMetadata = store.getMetadata(snapshot); final Store.MetadataSnapshot recoverySourceMetadata;
try {
recoverySourceMetadata = store.getMetadata(snapshot);
} catch (CorruptIndexException | IndexFormatTooOldException | IndexFormatTooNewException ex) {
shard.engine().failEngine("recovery", ex);
throw ex;
}
for (String name : snapshot.getFiles()) { for (String name : snapshot.getFiles()) {
final StoreFileMetaData md = recoverySourceMetadata.get(name); final StoreFileMetaData md = recoverySourceMetadata.get(name);
if (md == null) { if (md == null) {