Repository: flink
Updated Branches:
  refs/heads/release-1.5 64b32ecb6 -> b7532cb73


[FLINK-9214] [tests, yarn] YarnClient should be stopped in 
YARNSessionCapacitySchedulerITCase#testDetachedPerJobYarnClusterInternal

This closes #5892


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f1d536a9
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f1d536a9
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f1d536a9

Branch: refs/heads/release-1.5
Commit: f1d536a943ee19c9224b65b63d31b9dde72fe707
Parents: 64b32ec
Author: yanghua <[email protected]>
Authored: Sun Apr 22 16:38:28 2018 +0800
Committer: Stephan Ewen <[email protected]>
Committed: Mon Apr 30 23:24:51 2018 +0200

----------------------------------------------------------------------
 .../apache/flink/yarn/YARNSessionCapacitySchedulerITCase.java  | 6 ++++++
 1 file changed, 6 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/f1d536a9/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionCapacitySchedulerITCase.java
----------------------------------------------------------------------
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
index 3c442b9..4bbd500 100644
--- 
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 class YARNSessionCapacitySchedulerITCase extends 
YarnTestBase {
                                
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);
+                       }
                }
        }
 

Reply via email to