pnowojski opened a new pull request #15007: URL: https://github.com/apache/flink/pull/15007
This is a backport of https://github.com/apache/flink/pull/15000 When job is stopping with savepoint WITH drain flag (terminating), there is no intention to resume the job ever from that savepoint. Hence we have to make sure that we flush all of the buffered records from the job. To do that, we need to invoke endOfInput. ## Verifying this change This change adds a couple of new test in `StreamTaskTest` ---------------------------------------------------------------- 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: [email protected]
