sollhui opened a new pull request, #66091:
URL: https://github.com/apache/doris/pull/66091
### What problem does this PR solve?
Related PR: #66016
The first close stage waits only for non-incremental streams, but
`_quorum_success()` iterates the complete stream map. Incremental streams
outside that close stage were therefore treated as already finished and could
satisfy quorum before the shared dummy stream closed. An early source could
then close incremental streams before a late source opened them.
Snapshot the streams participating in each close stage. A destination now
contributes to quorum only when it participates in that stage and all of its
participating streams have finished. Nodes remain eligible for quorum in every
stage where they actually have close work; incremental opens no longer leak
into the first-stage close calculation.
### Release note
None
### Check List (For Author)
- Test
- [x] Unit Test added
- [ ] Unit Test run locally (dependency initialization was skipped)
- Behavior changed:
- [x] No
- Does this need documentation?
- [x] No
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
