Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5216#discussion_r160683957
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
---
@@ -272,6 +275,7 @@ public void testJavaAPI() throws Exception {
LOG.info("Shutting down cluster. All tests passed");
// shutdown cluster
yarnCluster.shutdown();
+ clusterDescriptor.close();
--- End diff --
will refactor it---
