the log I added as follows:
> [image: image.png]
>
> For deregisterApplication, I do not see any related log like "Shut
> down cluster because application is in {}, diagnostics {}.".
> Can anyone give me some suggestions? Thank you.
>
>
>
>
>
> --
Where exactly did you add your own log message?
WebMonitorEndpoint.closeAsync() already logs on it's own whether the
shutdown future was completed; meaning that it shouldn't have been
necessary to add a separate log message.
If you now only see the one you added, chances are that it was added a
I am using flink 1.10.0. My perJob can not be cancelled. From the log
I find that webMonitorEndpoint.closeAsync() is completed but
deregisterApplication is not called. The related code is as follows:
public CompletableFuture deregisterApplicationAndClose(
final ApplicationStatus appli