[SERVER-85624] Check more often for sink errors Created: 23/Jan/24 Updated: 26/Jan/24 Resolved: 26/Jan/24 |
|
| Status: | Closed |
| Project: | Core Server |
| Component/s: | None |
| Affects Version/s: | None |
| Fix Version/s: | None |
| Type: | Bug | Priority: | Major - P3 |
| Reporter: | Mayuresh Kulkarni | Assignee: | Mayuresh Kulkarni |
| Resolution: | Fixed | Votes: | 0 |
| Labels: | None | ||
| Remaining Estimate: | Not Specified | ||
| Time Spent: | Not Specified | ||
| Original Estimate: | Not Specified | ||
| Issue Links: |
|
||||||||
| Assigned Teams: |
Atlas Streams
|
||||||||
| Backwards Compatibility: | Fully Compatible | ||||||||
| Operating System: | ALL | ||||||||
| Sprint: | Sprint 41 | ||||||||
| Participants: | |||||||||
| Description |
|
For the queued sink operators, the helper thread that is pushing docs to the external system may run into an error. Currently, we will catch this situation in the top level runOnce , but, we should somehow make it so , so that we catch it earlier , so that if we are emitting a large batch of docs, we will not end up blocking on a full queue. |