Uploaded image for project: 'Core Server'
  1. Core Server
  2. SERVER-82102

Streams: fix stop flow when $emit connection fails

    • Type: Icon: Task Task
    • Resolution: Fixed
    • Priority: Icon: Major - P3 Major - P3
    • 7.2.0-rc0
    • Affects Version/s: None
    • Component/s: None
    • Atlas Streams
    • Fully Compatible
    • Sprint 33

      {"t":

      {"$date":"2023-10-11T21:12:13.633+00:00"}

      ,"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":

      {"$date":"2023-10-11T21:12:13.633+00:00"}

      ,"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":

      {"$date":"2023-10-11T21:12:13.633+00:00"}

      ,"s":"F", "c":"ASSERT", "id":23080, "ctx":"thread4700","msg":"\n\n***aborting after invariant() failure\n\n"}

      {"t":

      {"$date":"2023-10-11T21:12:13.633+00:00"}

      ,"s":"F", "c":"CONTROL", "id":6384300, "ctx":"thread4700","msg":"Writing fatal message","attr":{"message":"\n"}}

            Assignee:
            matthew.normyle@mongodb.com Matthew Normyle
            Reporter:
            matthew.normyle@mongodb.com Matthew Normyle
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

              Created:
              Updated:
              Resolved: