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

IteratorSourceReaderBase should report END_OF_INPUT sooner

    XMLWordPrintableJSON

Details

    • Technical Debt
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 1.17.0
    • 1.20.0
    • API / Core
    • None

    Description

      The iterator source reader base does not report end_of_input when the last value was emitted, but instead requires an additional call to pollNext to be made.
      This is fine functionality-wise, and allowed by the the source reader api contracts, but it's not intuitive behavior and leaks into tests for the datagen source.

      Attachments

        Activity

          People

            chesnay Chesnay Schepler
            chesnay Chesnay Schepler
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: