Skip to content

Commit

Permalink
No need to remove node metadata since we always overwrite it
Browse files Browse the repository at this point in the history
  • Loading branch information
DaveCTurner committed May 7, 2019
1 parent e805ec3 commit 3320d5a
Showing 1 changed file with 0 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -106,15 +106,6 @@ private IllegalStateException expectThrowsOnRestart(CheckedConsumer<Path[], Exce
@Override
public Settings onNodeStopped(String nodeName) {
try {
for (Path dataPath : dataPaths) {
try (Stream<Path> stateFiles = Files.list(dataPath.resolve(MetaDataStateFormat.STATE_DIR_NAME))) {
for (Path path : stateFiles.collect(Collectors.toList())) {
if (path.getFileName().toString().startsWith(NodeMetaData.FORMAT.getPrefix())) {
IOUtils.rm(path);
}
}
}
}
onNodeStopped.accept(dataPaths);
} catch (Exception e) {
throw new AssertionError(e);
Expand Down

0 comments on commit 3320d5a

Please sign in to comment.