flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
/**
	 * Test querying the YARN cluster.
	 *
	 * <p>This test validates through 666*2 cores in the "cluster".
	 */
Test querying the YARN cluster.
This test validates through 666*2 cores in the "cluster".
Test querying the YARN cluster . This test validates through 666 * 2 cores in the " cluster " .
@Test
	public void testQueryCluster() {
		LOG.info("Starting testQueryCluster()");
		runWithArgs(new String[] {"-q"}, "Summary: totalMemory 8192 totalCores 1332", null, RunTypes.YARN_SESSION, 0); 
		LOG.info("Finished testQueryCluster()");
	}
@ Test public void testQueryCluster ( ) { LOG . info ( "Starting testQueryCluster()" ) ; runWithArgs ( new String [ ] { "-q" } , "Summary: totalMemory 8192 totalCores 1332" , null , RunTypes . YARN_SESSION , 0 ) ; LOG . info ( "Finished testQueryCluster()" ) ; }
Test querying the YARN cluster.
Test querying the YARN cluster .
// we have 666*2 cores.