Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-3456

Backpressure Monitoring does not work for Kafka Sources

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Not A Problem
    • Affects Version/s: 1.0.0
    • Fix Version/s: None
    • Labels:
      None

      Description

      For sources that run with Kafka 0.8, the main thread is not the thread that processes elements and pushes them into the network. The Kafka fetcher threads actually emit elements to the SourceContext.

      Because the backpressure sampler samples the main thread, it does not correctly handle Kafka Sources.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                sewen Stephan Ewen
              • Votes:
                0 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: