@tillrohrmann currently our production codes never deal with the message send by `notifyObservers`, because the only class deal with this message is `ActorGatewayTaskExecutionStateListener` who is only used in `TaskTest`. In other word, these message are never sent to `JobMaster`. So replace them with `TaskManagerActions.updateTaskExecutionState` increase messages sent to `JobMaster`.
[ Full content available at: https://github.com/apache/flink/pull/6729 ] This message was relayed via gitbox.apache.org for [email protected]
