stevenzwu commented on pull request #14595: URL: https://github.com/apache/flink/pull/14595#issuecomment-758765285
@davidwys yes, the motivation is to be able to cancel the job after a certain number of elements. I didn't realize that closing the iterator from CloseableIterator<T> can cancel the job as well. Will close this PR and jira. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
