Repository: cassandra Updated Branches: refs/heads/trunk f0178266e -> cc02e9059
simplify, use already created snapshotName Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/cc02e905 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/cc02e905 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/cc02e905 Branch: refs/heads/trunk Commit: cc02e9059797e9c84940237503e8257d49defb4f Parents: f017826 Author: Dave Brosius <dbros...@mebigfatguy.com> Authored: Sat Jan 7 23:10:01 2017 -0500 Committer: Dave Brosius <dbros...@mebigfatguy.com> Committed: Sat Jan 7 23:10:01 2017 -0500 ---------------------------------------------------------------------- src/java/org/apache/cassandra/service/ActiveRepairService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/cc02e905/src/java/org/apache/cassandra/service/ActiveRepairService.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/service/ActiveRepairService.java b/src/java/org/apache/cassandra/service/ActiveRepairService.java index 1e89c8b..7476cd9 100644 --- a/src/java/org/apache/cassandra/service/ActiveRepairService.java +++ b/src/java/org/apache/cassandra/service/ActiveRepairService.java @@ -639,7 +639,7 @@ public class ActiveRepairService implements IEndpointStateChangeSubscriber, IFai if (isAlreadyRepairing(cfId, parentSessionId, snapshottedSSTables)) { - columnFamilyStores.get(cfId).clearSnapshot(parentSessionId.toString()); + columnFamilyStores.get(cfId).clearSnapshot(snapshotName); logger.error("Cannot start multiple repair sessions over the same sstables"); throw new RuntimeException("Cannot start multiple repair sessions over the same sstables"); }
