kezhuw commented on pull request #14831: URL: https://github.com/apache/flink/pull/14831#issuecomment-783232055
Hi @gaoyunhaii, I have seen FLIP-147 for reference about caveat of end-of-input handling. Basically, I have no more concerns, assumes that end-of-input should only flush buffered/aggregated but not new records. Hope it is documented somewhere in javadoc in future pr for that end-of-input-flushing method. ---------------------------------------------------------------- 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
