Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-2408

Flink unbounded source does not emit watermarks when there are multiple Readers

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • P0
    • Resolution: Fixed
    • 2.0.0, 2.1.0
    • 2.1.0
    • runner-flink
    • None

    Description

      In UnboundedSourceWrapper.run() there is simply no call to setNextWatermarkTimer() if the source has multiple readers. There is also no test for watermark emission so while fixing this we should add one to UnboundedSourceWrapperTest.

      Attachments

        Issue Links

          is related to

          Test - A new unit, integration or system test. BEAM-160 Port 'NexMark Queries' to Beam for use as integration test

          • P2 - Default priority. Will be triaged and planned according to community practices.
          • Resolved

          Activity

            People

              aljoscha Aljoscha Krettek
              aljoscha Aljoscha Krettek
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: