org.apache.flink.runtime.minicluster

Class StandaloneMiniCluster

java.lang.Object

org.apache.flink.runtime.minicluster.StandaloneMiniCluster

All Implemented Interfaces:

AutoCloseable, AutoCloseableAsync

public class StandaloneMiniCluster
extends Object
implements AutoCloseableAsync

Mini cluster to run the old JobManager code without embedded high availability services. This class has been implemented because the normal FlinkMiniCluster has been changed to use the HighAvailabilityServices. With this change we can no longer use the RemoteEnvironment to connect against the FlinkMiniCluster, because the remote environment cannot retrieve the current leader session id.

Constructor Summary

Constructors

Constructor and Description
StandaloneMiniCluster(Configuration configuration)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	closeAsync() Trigger the closing of the resource and return the corresponding close future.
Configuration	getConfiguration()
String	getHostname()
int	getPort()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.util.AutoCloseableAsync

close

Constructor Detail

StandaloneMiniCluster

public StandaloneMiniCluster(Configuration configuration)
                      throws Exception

Throws:

Exception

Method Detail

getHostname

public String getHostname()

getPort

public int getPort()

getConfiguration

public Configuration getConfiguration()

closeAsync

public CompletableFuture<Void> closeAsync()

Description copied from interface: AutoCloseableAsync

Trigger the closing of the resource and return the corresponding close future.

Specified by:

closeAsync in interface AutoCloseableAsync

Returns:

Future which is completed once the resource has been closed