I looked at the StreamTask, the initialization logic of the asynchronousCheckpointExceptionHandler is in the invoke method and before the call to the concrete init method. The invoke method has been marked as final. So, I personally feel that we don't have to make this thing too complicated, just to reduce a null judgment. What do you think?
[ Full content available at: https://github.com/apache/flink/pull/6567 ] This message was relayed via gitbox.apache.org for [email protected]
