[FLINK-32715][test] Make test wait for application to stop before shu…

…tting down the other services (#23104)
apache · Aug 2, 2023 · 99b9833 · 99b9833
1 parent 2a1ae11
commit 99b9833
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/flink-tests/src/test/java/org/apache/flink/test/recovery/ProcessFailureCancelingITCase.java b/flink-tests/src/test/java/org/apache/flink/test/recovery/ProcessFailureCancelingITCase.java
@@ -238,8 +238,9 @@ public Long map(Long value) throws Exception {
  taskManagerProcess.destroy();
  }
  if (dispatcherResourceManagerComponent != null) {
- dispatcherResourceManagerComponent.stopApplication(
- ApplicationStatus.SUCCEEDED, null);
+ dispatcherResourceManagerComponent
+ .stopApplication(ApplicationStatus.SUCCEEDED, null)
+ .get();
  }
 
  fatalErrorHandler.rethrowError();