You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mx...@apache.org on 2016/09/06 10:56:02 UTC
flink git commit: [FLINK-4073] remove unstable testing code in
TaskManagerFailure test
Repository: flink
Updated Branches:
refs/heads/master 2f87f61d3 -> 87aea72f1
[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/master
Commit: 87aea72f181d0945092538384037acb0da364b9e
Parents: 2f87f61
Author: Maximilian Michels <mx...@apache.org>
Authored: Tue Sep 6 12:22:04 2016 +0200
Committer: Maximilian Michels <mx...@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>();