diff --git a/internal/datacoord/segment_manager.go b/internal/datacoord/segment_manager.go
index 8ce1fb75ef..bdcda75015 100644
--- a/internal/datacoord/segment_manager.go
+++ b/internal/datacoord/segment_manager.go
@@ -327,8 +327,7 @@ func (s *SegmentManager) openNewSegment(ctx context.Context, collectionID Unique
 		zap.Int("Rows", maxNumOfRows),
 		zap.String("Channel", segmentInfo.InsertChannel))
 
-	s.helper.afterCreateSegment(segmentInfo)
-	return segment, nil
+	return segment, s.helper.afterCreateSegment(segmentInfo)
 }
 
 func (s *SegmentManager) estimateMaxNumOfRows(collectionID UniqueID) (int, error) {