Repository: flink Updated Branches: refs/heads/master d2de75e45 -> 432e48a2e
[hotfix] Harden YARNSessionCapacitySchedulerITCase#testTaskManagerFailure by removing timeout We should wait until the runner has completed fully. Otherwise we might risk that the Yarn application has not been fully shut down. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/432e48a2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/432e48a2 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/432e48a2 Branch: refs/heads/master Commit: 432e48a2e5f8b7045816ea39799156b2d16ea13b Parents: d2de75e Author: Till Rohrmann <[email protected]> Authored: Sat Jun 30 23:53:16 2018 +0200 Committer: Till Rohrmann <[email protected]> Committed: Sat Jun 30 23:53:16 2018 +0200 ---------------------------------------------------------------------- .../org/apache/flink/yarn/YARNSessionCapacitySchedulerITCase.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/432e48a2/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 f0a5175..99ebcd1 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 @@ -331,7 +331,7 @@ public class YARNSessionCapacitySchedulerITCase extends YarnTestBase { runner.sendStop(); // wait for the thread to stop try { - runner.join(1000); + runner.join(); } catch (InterruptedException e) { LOG.warn("Interrupted while stopping runner", e); }
