Skip to content

Commit

Permalink
Properly return response if SegmentCompletion is aborted (apache#13206)
Browse files Browse the repository at this point in the history
  • Loading branch information
harold-kfuse authored May 23, 2024
1 parent 3c4fe72 commit ca7ab24
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit ca7ab24

Please sign in to comment.