|
|
@@ -495,8 +495,7 @@ public class RecoveryTarget extends AbstractRefCounted implements RecoveryTarget
|
|
|
final Store store = store();
|
|
|
store.incRef();
|
|
|
try {
|
|
|
- if (DiscoveryNode.isStateless(indexShard.indexSettings().getNodeSettings()) == false
|
|
|
- || indexShard.routingEntry().primary()) {
|
|
|
+ if (indexShard.routingEntry().isPromotableToPrimary()) {
|
|
|
store.cleanupAndVerify("recovery CleanFilesRequestHandler", sourceMetadata);
|
|
|
}
|
|
|
final String translogUUID = Translog.createEmptyTranslog(
|