File tree 1 file changed +0
-6
lines changed
src/main/java/com/spotify/reaper/service
1 file changed +0
-6
lines changed Original file line number Diff line number Diff line change @@ -217,17 +217,11 @@ private void startNextSegment() {
217
217
// Just checking that no currently running segment runner is stuck.
218
218
RepairSegment supposedlyRunningSegment =
219
219
context .storage .getRepairSegment (currentlyRunningSegments .get (rangeIndex )).get ();
220
- if (supposedlyRunningSegment .getState () == RepairSegment .State .DONE ) {
221
- LOG .warn ("Segment #{} supposedly running in slot {} has state: {}" ,
222
- supposedlyRunningSegment .getId (), rangeIndex ,
223
- supposedlyRunningSegment .getState ().toString ());
224
- }
225
220
DateTime startTime = supposedlyRunningSegment .getStartTime ();
226
221
if (startTime != null && startTime .isBefore (DateTime .now ().minusDays (1 ))) {
227
222
LOG .warn ("Looks like segment #{} has been running more than a day. Start time: {}" ,
228
223
supposedlyRunningSegment .getId (), supposedlyRunningSegment .getStartTime ());
229
224
}
230
-
231
225
// No need to try starting new repair for already active slot.
232
226
continue ;
233
227
}
You can’t perform that action at this time.
0 commit comments