diff --git a/orchestrator/stage/stages.go b/orchestrator/stage/stages.go
index 32fdd1ac1..e2e9237c0 100644
--- a/orchestrator/stage/stages.go
+++ b/orchestrator/stage/stages.go
@@ -322,7 +322,7 @@ func (s *Stages) MergeCompleted(mergeUnit Unit) {
 
 func (s *Stages) MoveSegmentCompletedForward(stageIdx int) {
 	stage := s.stages[stageIdx]
-	for i := stage.segmentCompleted + 1; i < stage.segmenter.LastIndex(); i++ {
+	for i := stage.segmentCompleted + 1; i <= stage.segmenter.LastIndex(); i++ {
 		unit := Unit{Stage: stageIdx, Segment: i}
 		if s.getState(unit) == UnitCompleted {
 			stage.segmentCompleted = i