Fix FSNameSystem.addSafeBlocks()
@@ -7688,7 +7688,7 @@ private int addSafeBlocks(final List<Long> safeBlocks) throws IOException {
@Override
public void handle(int startIndex, int endIndex) throws Exception {
final List<Long> ids = safeBlocks.subList(startIndex, endIndex);
- addSafeBlocksTX(safeBlocks, added);
+ addSafeBlocksTX(ids, added);
}
});
} catch (Exception e) {
