diff --git a/pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/realtime/SegmentCompletionManager.java b/pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/realtime/SegmentCompletionManager.java index b593da230c09..7672addb3bea 100644 --- a/pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/realtime/SegmentCompletionManager.java +++ b/pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/realtime/SegmentCompletionManager.java @@ -1000,7 +1000,7 @@ private SegmentCompletionProtocol.Response processConsumedAfterCommitStart(Strin // If the winner is coming back again, then we have some more conditions to look at. response = abortIfTooLateAndReturnHold(now, instanceId, offset); if (response != null) { - return null; + return response; } if (instanceId.equals(_winner)) { // The winner is coming back to report its offset. Take a decision based on the offset reported, and whether we