This is an automated email from the ASF dual-hosted git repository.
jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new ca7ab248dc Properly return response if SegmentCompletion is aborted
(#13206)
ca7ab248dc is described below
commit ca7ab248dca7e1247ec6739fd6068aadc98255b7
Author: harold-kfuse <[email protected]>
AuthorDate: Wed May 22 17:02:56 2024 -0700
Properly return response if SegmentCompletion is aborted (#13206)
---
.../pinot/controller/helix/core/realtime/SegmentCompletionManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 b593da230c..7672addb3b 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 @@ public class SegmentCompletionManager {
// 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
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
