[SERVER-82102] Streams: fix stop flow when $emit connection fails Created: 11/Oct/23 Updated: 29/Nov/23 Resolved: 13/Oct/23 |
|
| Status: | Closed |
| Project: | Core Server |
| Component/s: | None |
| Affects Version/s: | None |
| Fix Version/s: | 7.2.0-rc0 |
| Type: | Task | Priority: | Major - P3 |
| Reporter: | Matthew Normyle | Assignee: | Matthew Normyle |
| Resolution: | Fixed | Votes: | 0 |
| Labels: | init-337-m3 | ||
| Remaining Estimate: | Not Specified | ||
| Time Spent: | Not Specified | ||
| Original Estimate: | Not Specified | ||
| Assigned Teams: |
Atlas Streams
|
| Backwards Compatibility: | Fully Compatible |
| Sprint: | Sprint 33 |
| Participants: |
| Description |
|
{"t": ,"s":"W", "c":"STREAMS", "id":75899, "ctx":"thread4700","msg":"encountered exception, exiting runLoop(): {error}","attr":{"context": {"streamProcessorName":"eriktest","streamProcessorId":"6524304d6b9f6f609c2c6ac9","tenantId":"6509e58bfd98a76e09b7f80a"},"errorCode":74686,"reason":"$emit to Kafka encountered error while flushing, kafka error code: -185","error":"$emit to Kafka encountered error while flushing, kafka error code: -185"}} {"t": ,"s":"F", "c":"ASSERT", "id":23079, "ctx":"thread4700","msg":"Invariant failure","attr":{"expr":"processorInfo->streamStatus == StreamStatusEnum::Running","file":"src/mongo/db/modules/enterprise/src/streams/management/stream_manager.cpp","line":714}} {"t": ,"s":"F", "c":"ASSERT", "id":23080, "ctx":"thread4700","msg":"\n\n***aborting after invariant() failure\n\n"} {"t": ,"s":"F", "c":"CONTROL", "id":6384300, "ctx":"thread4700","msg":"Writing fatal message","attr":{"message":"\n"}} |