|
@@ -2026,6 +2026,7 @@ public abstract class BlobStoreRepository extends AbstractLifecycleComponent imp
|
|
|
private void markRepoCorrupted(long corruptedGeneration, Exception originalException, ActionListener<Void> listener) {
|
|
|
assert corruptedGeneration != RepositoryData.UNKNOWN_REPO_GEN;
|
|
|
assert bestEffortConsistency == false;
|
|
|
+ logger.warn(() -> "Marking repository [" + metadata.name() + "] as corrupted", originalException);
|
|
|
submitUnbatchedTask(
|
|
|
"mark repository corrupted [" + metadata.name() + "][" + corruptedGeneration + "]",
|
|
|
new ClusterStateUpdateTask() {
|