diff --git a/src/main/java/com/spotify/reaper/service/SegmentRunner.java b/src/main/java/com/spotify/reaper/service/SegmentRunner.java index 6a63cbace..e6fe5ec24 100644 --- a/src/main/java/com/spotify/reaper/service/SegmentRunner.java +++ b/src/main/java/com/spotify/reaper/service/SegmentRunner.java @@ -120,7 +120,7 @@ public static void postpone(AppContext context, RepairSegment segment, Optional< } public static void abort(AppContext context, RepairSegment segment, JmxProxy jmxConnection) { - postpone(context, segment, Optional.fromNullable((RepairUnit) null)); + postpone(context, segment, context.storage.getRepairUnit(segment.getRepairUnitId())); LOG.info("Aborting repair on segment with id {} on coordinator {}", segment.getId(), segment.getCoordinatorHost()); jmxConnection.cancelAllRepairs();