flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-tests/src/test/java/org/apache/flink/test/operators/RemoteEnvironmentITCase.java
/**
	 * Ensure that that Akka configuration parameters can be set.
	 */
Ensure that that Akka configuration parameters can be set.
Ensure that that Akka configuration parameters can be set .
@Test(expected = FlinkException.class)
	public void testInvalidAkkaConfiguration() throws Throwable {
		Configuration config = new Configuration();
		config.setString(AkkaOptions.STARTUP_TIMEOUT, INVALID_STARTUP_TIMEOUT);
		final ExecutionEnvironment env = ExecutionEnvironment.createRemoteEnvironment(
				cluster.getHostname(),
				cluster.getPort(),
				config
		);
		env.getConfig().disableSysoutLogging();
		DataSet<String> result = env.createInput(new TestNonRichInputFormat());
		result.output(new LocalCollectionOutputFormat<>(new ArrayList<String>()));
		try {
			env.execute();
			Assert.fail("Program should not run successfully, cause of invalid akka settings.");
		} catch (ProgramInvocationException ex) {
			throw ex.getCause();
		}
	}
@ Test ( expected = FlinkException . class ) public void testInvalidAkkaConfiguration ( ) throws Throwable { Configuration config = new Configuration ( ) ; config . setString ( AkkaOptions . STARTUP_TIMEOUT , INVALID_STARTUP_TIMEOUT ) ; final ExecutionEnvironment env = ExecutionEnvironment . createRemoteEnvironment ( cluster . getHostname ( ) , cluster . getPort ( ) , config ) ; env . getConfig ( ) . disableSysoutLogging ( ) ; DataSet < String > result = env . createInput ( new TestNonRichInputFormat ( ) ) ; result . output ( new LocalCollectionOutputFormat < > ( new ArrayList < String > ( ) ) ) ; try { env . execute ( ) ; Assert . fail ( "Program should not run successfully, cause of invalid akka settings." ) ; } catch ( ProgramInvocationException ex ) { throw ex . getCause ( ) ; } }
Ensure that that Akka configuration parameters can be set.
Ensure that that Akka configuration parameters can be set .