浏览代码

Call verify on index input after copying

Simon Willnauer 10 年之前
父节点
当前提交
d9b68a7674
共有 1 个文件被更改,包括 1 次插入0 次删除
  1. 1 0
      core/src/main/java/org/elasticsearch/indices/recovery/RecoverySourceHandler.java

+ 1 - 0
core/src/main/java/org/elasticsearch/indices/recovery/RecoverySourceHandler.java

@@ -674,6 +674,7 @@ public class RecoverySourceHandler {
                     try (final OutputStream outputStream = outputStreamFactory.apply(md);
                          final IndexInput indexInput = store.directory().openInput(md.name(), IOContext.READONCE)) {
                         Streams.copy(new InputStreamIndexInput(indexInput, md.length()), outputStream);
+                        Store.verify(indexInput);
                     }
                     return null;
                 });