[FLINK-9214] [tests, yarn] YarnClient should be stopped in YARNSessio…

…nCapacitySchedulerITCase#testDetachedPerJobYarnClusterInternal This closes apache#5892
tongcheng-elong · Apr 30, 2018 · bd8cb86 · bd8cb86
1 parent 07aa2d4
commit bd8cb86
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionCapacitySchedulerITCase.java b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionCapacitySchedulerITCase.java
@@ -590,6 +590,12 @@ public boolean accept(File dir, String name) {
  LOG.warn("testDetachedPerJobYarnClusterInternal: Exception while deleting the JobManager address file", e);
  }
 
+ try {
+ LOG.info("testDetachedPerJobYarnClusterInternal: Closing the yarn client");
+ yc.stop();
+ } catch (Exception e) {
+ LOG.warn("testDetachedPerJobYarnClusterInternal: Exception while close the yarn client", e);
+ }
  }
  }