This is an automated email from the ASF dual-hosted git repository. xtsong pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit cb478fb751dbe28405152707040f9126b5a5269b Author: Xintong Song <[email protected]> AuthorDate: Sun Feb 20 19:51:42 2022 +0800 Revert "[FLINK-25885] Suppress error reporting for ResourceManagerServiceImpl.deregisterApplication" This reverts commit 59d2d84d83696d4775b6ff3ec97f8274ff6e371f. close #18853 --- .../component/DispatcherResourceManagerComponent.java | 12 +----------- 1 file changed, 1 insertion(+), 11 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/DispatcherResourceManagerComponent.java b/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/DispatcherResourceManagerComponent.java index 7a95020..7fa5db9 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/DispatcherResourceManagerComponent.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/DispatcherResourceManagerComponent.java @@ -129,17 +129,7 @@ public class DispatcherResourceManagerComponent implements AutoCloseableAsync { public CompletableFuture<Void> stopApplication( final ApplicationStatus applicationStatus, final @Nullable String diagnostics) { return internalShutdown( - () -> - resourceManagerService - .deregisterApplication(applicationStatus, diagnostics) - // suppress deregister exception because of FLINK-25893 - .exceptionally( - exception -> { - LOG.warn( - "Could not properly deregister the application.", - exception); - return null; - })); + () -> resourceManagerService.deregisterApplication(applicationStatus, diagnostics)); } /**
