You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2019/01/23 14:01:15 UTC
[flink] branch master updated: [FLINK-11348][tests] Port
testClientStartup to new codebase
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 3f0b1df [FLINK-11348][tests] Port testClientStartup to new codebase
3f0b1df is described below
commit 3f0b1dfc4da548b166bc3e6aaf4d694c52ddda7b
Author: Gary Yao <ga...@data-artisans.com>
AuthorDate: Fri Jan 18 14:28:18 2019 +0100
[FLINK-11348][tests] Port testClientStartup to new codebase
Port YARNSessionCapacitySchedulerITCase#testClientStartup to new flip6 codebase.
Rename test to testStartYarnSessionClusterInQaTeamQueue.
Remove -n command line parameter & argument.
---
.../apache/flink/yarn/YARNSessionCapacitySchedulerITCase.java | 11 ++++-------
1 file changed, 4 insertions(+), 7 deletions(-)
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 1009fbb..83abd8a 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
@@ -99,18 +99,15 @@ public class YARNSessionCapacitySchedulerITCase extends YarnTestBase {
}
/**
- * Test regular operation, including command line parameter parsing.
+ * Tests that a session cluster, that uses the resources from the <i>qa-team</i> queue,
+ * can be started from the command line.
*/
@Test
- public void testClientStartup() throws IOException {
- assumeTrue("The new mode does not start TMs upfront.", !isNewMode);
- LOG.info("Starting testClientStartup()");
+ public void testStartYarnSessionClusterInQaTeamQueue() throws IOException {
runWithArgs(new String[]{"-j", flinkUberjar.getAbsolutePath(), "-t", flinkLibFolder.getAbsolutePath(),
- "-n", "1",
"-jm", "768m",
"-tm", "1024m", "-qu", "qa-team"},
- "Number of connected TaskManagers changed to 1. Slots available: 1", null, RunTypes.YARN_SESSION, 0);
- LOG.info("Finished testClientStartup()");
+ "Flink JobManager is now running on ", null, RunTypes.YARN_SESSION, 0);
}
/**