Re: Fail to cancel perJob for that deregisterApplication is not called

2021-05-21 Thread 刘建刚
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. > > > > > > --

Re: Fail to cancel perJob for that deregisterApplication is not called

2021-03-26 Thread Chesnay Schepler
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

Fail to cancel perJob for that deregisterApplication is not called

2021-03-23 Thread 刘建刚
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