[FLINK-4073] remove unstable testing code in TaskManagerFailure test Yarn reports null or (1, maxVcores) depending on its internal logic. The test only worked in the past because it summed up the used vcores of the RM and the TM containers. We have checks in place to ensure the vcores config value is passed on to the Flink ResourceManager.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/87aea72f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/87aea72f Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/87aea72f Branch: refs/heads/flip-6 Commit: 87aea72f181d0945092538384037acb0da364b9e Parents: 2f87f61 Author: Maximilian Michels <m...@apache.org> Authored: Tue Sep 6 12:22:04 2016 +0200 Committer: Maximilian Michels <m...@apache.org> Committed: Tue Sep 6 12:55:38 2016 +0200 ---------------------------------------------------------------------- .../YARNSessionCapacitySchedulerITCase.java | 21 -------------------- 1 file changed, 21 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/87aea72f/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 886ec32..ddea4dd 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 @@ -32,9 +32,6 @@ import org.apache.hadoop.yarn.api.protocolrecords.StopContainersRequest; import org.apache.hadoop.yarn.api.records.ApplicationId; import org.apache.hadoop.yarn.api.records.ApplicationReport; import org.apache.hadoop.yarn.api.records.ContainerId; -import org.apache.hadoop.yarn.api.records.NodeReport; -import org.apache.hadoop.yarn.api.records.NodeState; -import org.apache.hadoop.yarn.api.records.Resource; import org.apache.hadoop.yarn.api.records.YarnApplicationState; import org.apache.hadoop.yarn.client.api.YarnClient; import org.apache.hadoop.yarn.conf.YarnConfiguration; @@ -246,24 +243,6 @@ public class YARNSessionCapacitySchedulerITCase extends YarnTestBase { Assert.assertNotNull("Unable to find container with TaskManager", taskManagerContainer); Assert.assertNotNull("Illegal state", nodeManager); - try { - List<NodeReport> nodeReports = yc.getNodeReports(NodeState.RUNNING); - - // we asked for one node with 2 vcores so we expect 2 vcores - // note that the JobManager may also run on the NodeManager - boolean foundVCoresSetting = false; - for (NodeReport rep: nodeReports) { - Resource resource = rep.getUsed(); - if (resource != null && resource.getVirtualCores() == 2) { - foundVCoresSetting = true; - break; - } - } - Assert.assertTrue(foundVCoresSetting); - } catch (Exception e) { - Assert.fail("Test failed: " + e.getMessage()); - } - yc.stop(); List<ContainerId> toStop = new LinkedList<ContainerId>();
