Uploaded image for project: 'CDAP'
  1. CDAP
  2. CDAP-3458

Stream events are re-consumed in flows

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 3.1.0, 3.0.3
    • Fix Version/s: 3.2.0, 3.1.2, 3.0.5
    • Component/s: Streams
    • Labels:
    • Release Notes:
      Fixed a bug that prevents streams events that are already processed from being re-processed in flows.
    • Rank:
      1|hzyygn:

      Description

      Symptom: system.collect.events represents the count of events that are sent to the stream and system.process.events.in represents the events that are input to the flowlet. When stream is connected to the flowlet, then ideally system.collect.events should be larger or equal to the system.process.events.in of the connected flowlet. However sometimes events get re-read by the stream consumer causing same events to re-process again.

        Attachments

          Activity

            People

            • Assignee:
              terence Terence Yim
              Reporter:
              sagar Sagar Kapare
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: