Skip to content

Commit

Permalink
[FLINK-11348][tests] Port testClientStartup to new codebase
Browse files Browse the repository at this point in the history
Port YARNSessionCapacitySchedulerITCase#testClientStartup to new flip6 codebase.
Rename test to testStartYarnSessionClusterInQaTeamQueue.
Remove -n command line parameter & argument.
  • Loading branch information
GJL authored and tillrohrmann committed Jan 23, 2019
1 parent 1c4df99 commit 3f0b1df
Showing 1 changed file with 4 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -99,18 +99,15 @@ public static void setup() {
}

/**
* 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);
}

/**
Expand Down

0 comments on commit 3f0b1df

Please sign in to comment.