flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobClientSslTest.java
/**
	 * Starts the SSL enabled BLOB server.
	 */
Starts the SSL enabled BLOB server.
Starts the SSL enabled BLOB server .
@BeforeClass
	public static void startSSLServer() throws IOException {
		Configuration config = new Configuration();
		config.setString(BlobServerOptions.STORAGE_DIRECTORY,
			temporarySslFolder.newFolder().getAbsolutePath());
		config.setBoolean(SecurityOptions.SSL_ENABLED, true);
		config.setString(SecurityOptions.SSL_KEYSTORE, "src/test/resources/local127.keystore");
		config.setString(SecurityOptions.SSL_KEYSTORE_PASSWORD, "password");
		config.setString(SecurityOptions.SSL_KEY_PASSWORD, "password");
		BLOB_SSL_SERVER = new BlobServer(config, new VoidBlobStore());
		BLOB_SSL_SERVER.start();
		sslClientConfig = new Configuration();
		sslClientConfig.setBoolean(SecurityOptions.SSL_ENABLED, true);
		sslClientConfig.setString(SecurityOptions.SSL_TRUSTSTORE, "src/test/resources/local127.truststore");
		sslClientConfig.setString(SecurityOptions.SSL_TRUSTSTORE_PASSWORD, "password");
	}
@ BeforeClass public static void startSSLServer ( ) throws IOException { Configuration config = new Configuration ( ) ; config . setString ( BlobServerOptions . STORAGE_DIRECTORY , temporarySslFolder . newFolder ( ) . getAbsolutePath ( ) ) ; config . setBoolean ( SecurityOptions . SSL_ENABLED , true ) ; config . setString ( SecurityOptions . SSL_KEYSTORE , "src/test/resources/local127.keystore" ) ; config . setString ( SecurityOptions . SSL_KEYSTORE_PASSWORD , "password" ) ; config . setString ( SecurityOptions . SSL_KEY_PASSWORD , "password" ) ; BLOB_SSL_SERVER = new BlobServer ( config , new VoidBlobStore ( ) ) ; BLOB_SSL_SERVER . start ( ) ; sslClientConfig = new Configuration ( ) ; sslClientConfig . setBoolean ( SecurityOptions . SSL_ENABLED , true ) ; sslClientConfig . setString ( SecurityOptions . SSL_TRUSTSTORE , "src/test/resources/local127.truststore" ) ; sslClientConfig . setString ( SecurityOptions . SSL_TRUSTSTORE_PASSWORD , "password" ) ; }
Starts the SSL enabled BLOB server.
Starts the SSL enabled BLOB server .