Chesnay Schepler created FLINK-30290: ----------------------------------------
Summary: IteratorSourceReaderBase should report END_OF_INPUT sooner Key: FLINK-30290 URL: https://issues.apache.org/jira/browse/FLINK-30290 Project: Flink Issue Type: Technical Debt Components: API / Core Affects Versions: 1.17.0 Reporter: Chesnay Schepler Assignee: Chesnay Schepler Fix For: 1.17.0 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. -- This message was sent by Atlassian Jira (v8.20.10#820010)