## What is the purpose of the change After a discussion [here](https://github.com/apache/flink/commit/0735b5b935b0c0757943e2d58047afcfb9949560#commitcomment-30584257) with @tillrohrmann . I start to analyze the usage of `ActorGatewayTaskExecutionStateListener` and `TaskExecutionStateListener`.
In conclusion, we abort `TaskExecutionStateListener` strategy and no any component rely on it. Instead, we introduce `TaskManagerActions` to take the role for the communication of `Task` with `TaskManager`. No one except `TaskManager` should directly communicate with `Task`. So it can be safely remove legacy class `TaskExecutionStateListener`. ## Brief change log - Wholly Remove `ActorGatewayTaskExecutionStateListener.java` and `TaskExecutionStateListener.java` - Graceful remove inactive usage of these class in `Task.java` - Refine `TaskTest.java` and `StreamTaskTest.java` ## Verifying this change Since it is a removal, make sure existing tests pass is enough. cc @tillrohrmann @GJL @twalthr [ Full content available at: https://github.com/apache/flink/pull/6729 ] This message was relayed via gitbox.apache.org for [email protected]
