[FLINK-22972] Deprecate/Remove StreamOperator#dispose method

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 1.14.0
• Component/s: API / Core, Runtime / Task
• Labels: pull-request-available
• Assignee: Dawid Wysakowicz
• Reporter: Dawid Wysakowicz
• Created: 11/Jun/21 07:48
• Updated: 12/Apr/22 13:02
• Resolved: 06/Jul/21 06:24

Description

As discussed in the ML thread (e.g. https://lists.apache.org/thread.html/r34a05c77bddb2a7cb550c0b820d2a4aa8e1be882fc81bee501fb74e8%40%3Cdev.flink.apache.org%3E) we want to clean up the contract of close and dispose methods.

We suggest introducing a new method finish(), deprecate or remove the dispose method and extract finish() part out of the close().

Issue Links

• relates to: FLINK-27202 NullPointerException on stop-with-savepoint with AsyncWaitOperator followed by FlinkKafkaProducer
• links to: GitHub Pull Request #16351