Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2849
I would actually not do that change. Partially initialized operators should
receive a call to `cleanup()`.
The cancellation/shutdown logic is quite tricky - mainly because of some
legacy way to instantiate the tasks and operators.
The right way to fix this is to actually follow the proper RAII pattern.
That means:
- going away from instantiating a blank invokable class, but having an
invokable with a constructors that takes the `ExecutionEnvironment`
- Change the `StreamOperator` to be more a factory for the actual
operator, and instantiate it in the constructor of the task.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
