Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5892#discussion_r183395091
--- Diff:
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.close();
+ } catch (IOException e) {
--- End diff --
Catch all exceptions instead. According to the docs `IOExceptions` are
never thrown but `RuntimeExceptions` might be.
---
