From 53c75f7cf39a23a6b143dde65752aa9910df203a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Bj=C3=B6rn=20Hegerfors?= Date: Mon, 2 Feb 2015 18:43:11 +0100 Subject: [PATCH] Unset currentlyRunningSegmentId when not running a segment --- src/main/java/com/spotify/reaper/service/RepairRunner.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/spotify/reaper/service/RepairRunner.java b/src/main/java/com/spotify/reaper/service/RepairRunner.java index 5c54b71e3..ffa03be1c 100644 --- a/src/main/java/com/spotify/reaper/service/RepairRunner.java +++ b/src/main/java/com/spotify/reaper/service/RepairRunner.java @@ -121,7 +121,7 @@ public static void startRepairRun(IStorage storage, long repairRunID, @VisibleForTesting public Long getCurrentlyRunningSegmentId() { - return this.currentlyRunningSegmentId; + return currentlyRunningSegmentId; } /** @@ -245,9 +245,10 @@ private void repairSegment(long segmentId, RingRange tokenRange) throws ReaperEx return; } - this.currentlyRunningSegmentId = Long.valueOf(segmentId); + currentlyRunningSegmentId = segmentId; SegmentRunner.triggerRepair(storage, segmentId, potentialCoordinators, repairTimeoutMillis, jmxConnectionFactory); + currentlyRunningSegmentId = null; handleResult(segmentId); }