Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1588#issuecomment-180753150
I didn't test this myself, but this diff could be sufficient for testing
your change:
```diff
diff --git
a/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
b/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
index 8c9a9c7..999b5be 100644
---
a/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
+++
b/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
@@ -180,6 +180,7 @@ public class YARNSessionFIFOITCase extends YarnTestBase
{
"-n", "1",
"-jm", "768",
"-tm", "1024",
+ "-s", "3", // set the slots 3 to check if
the vCores are set properly!
"-nm", "customName",
"-Dfancy-configuration-value=veryFancy",
"-Dyarn.maximum-failed-containers=3"},
@@ -268,6 +269,7 @@ public class YARNSessionFIFOITCase extends YarnTestBase
{
String command = Joiner.on("
").join(entry.getValue().getLaunchContext().getCommands());
if(command.contains(YarnTaskManagerRunner.class.getSimpleName())) {
taskManagerContainer =
entry.getKey();
+
Assert.assertEquals(3,entry.getValue().getResource().getVirtualCores());
nodeManager = nm;
nmIdent = new
NMTokenIdentifier(taskManagerContainer.getApplicationAttemptId(), null, "",0);
// allow myself to do stuff with
the container
```
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
