diff --git a/src/java/org/apache/cassandra/service/MigrationTask.java b/src/java/org/apache/cassandra/service/MigrationTask.java index 1fc1db13b8..8f3f0283ab 100644 --- a/src/java/org/apache/cassandra/service/MigrationTask.java +++ b/src/java/org/apache/cassandra/service/MigrationTask.java @@ -132,6 +132,7 @@ public boolean isLatencyForSnitch() catch (Exception e) { version.ifPresent(v -> MigrationManager.removeEndpointFromSchemaPullVersion(v, endpoint)); + throw e; } } }