org.apache.flink.test.util

Class ForkableFlinkMiniCluster

java.lang.Object

org.apache.flink.runtime.minicluster.FlinkMiniCluster

org.apache.flink.runtime.minicluster.LocalFlinkMiniCluster

org.apache.flink.test.util.ForkableFlinkMiniCluster

All Implemented Interfaces:

LeaderRetrievalListener

public class ForkableFlinkMiniCluster
extends LocalFlinkMiniCluster

A forkable mini cluster is a special case of the mini cluster, used for parallel test execution on build servers. If multiple tests run in parallel, the cluster picks up the fork number and uses it to avoid port conflicts.

Constructor Summary

Constructors

Constructor and Description
ForkableFlinkMiniCluster(Configuration userConfiguration)
ForkableFlinkMiniCluster(Configuration userConfiguration, boolean singleActorSystem)

Method Summary

Modifier and Type	Method and Description
Configuration	generateConfiguration(Configuration userConfiguration)
void	restartLeadingJobManager()
void	restartTaskManager(int index)
void	start()
static ForkableFlinkMiniCluster	startCluster(int numSlots, int numTaskManagers, String timeout)
akka.actor.ActorRef	startJobManager(int index, akka.actor.ActorSystem actorSystem)
akka.actor.ActorRef	startTaskManager(int index, akka.actor.ActorSystem system)
void	stop()
void	waitForTaskManagersToBeRegisteredAtJobManager(akka.actor.ActorRef jobManager)
scala.Option<org.apache.curator.test.TestingCluster>	zookeeperCluster()

Methods inherited from class org.apache.flink.runtime.minicluster.LocalFlinkMiniCluster

currentlyRunningJobs, getArchiveName, getCurrentlyRunningJobsJava, getDefaultConfig, getJobManagerName, getLeaderRPCPort, initializeIOFormatClasses, setMemory, stopJob

Methods inherited from class org.apache.flink.runtime.minicluster.FlinkMiniCluster

awaitTermination, clearLeader, configuration, createLeaderRetrievalService, executionContext, futureLock, getJobManagerAkkaConfig, getJobManagersAsJava, getLeaderGateway, getLeaderGatewayFuture, getLeaderIndex, getLeaderIndexFuture, getNumberOfJobManagers, getTaskManagerAkkaConfig, getTaskManagers, getTaskManagersAsJava, handleError, hostname, jobManagerActors, jobManagerActorSystems, leaderGateway, leaderIndex, leaderRetrievalService, LOG, notifyLeaderAddress, numJobManagers, numTaskManagers, recoveryMode, running, setDefaultCiConfig, shutdown, shutdownJobClientActorSystem, start, startJobClientActorSystem, startJobManagerActorSystem, startTaskManagerActorSystem, startWebServer, submitJobAndWait, submitJobAndWait, submitJobAndWait, submitJobDetached, taskManagerActors, taskManagerActorSystems, timeout, userConfiguration, useSingleActorSystem, waitForTaskManagersToBeRegistered, waitForTaskManagersToBeRegistered, webMonitor

Methods inherited from class java.lang.Object

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

Constructor Detail

ForkableFlinkMiniCluster

public ForkableFlinkMiniCluster(Configuration userConfiguration,
                                boolean singleActorSystem)

ForkableFlinkMiniCluster

public ForkableFlinkMiniCluster(Configuration userConfiguration)

Method Detail

startCluster

public static ForkableFlinkMiniCluster startCluster(int numSlots,
                                                    int numTaskManagers,
                                                    String timeout)

zookeeperCluster

public scala.Option<org.apache.curator.test.TestingCluster> zookeeperCluster()

generateConfiguration

public Configuration generateConfiguration(Configuration userConfiguration)

Overrides:

generateConfiguration in class LocalFlinkMiniCluster

startJobManager

public akka.actor.ActorRef startJobManager(int index,
                                           akka.actor.ActorSystem actorSystem)

Overrides:

startJobManager in class LocalFlinkMiniCluster

startTaskManager

public akka.actor.ActorRef startTaskManager(int index,
                                            akka.actor.ActorSystem system)

Overrides:

startTaskManager in class LocalFlinkMiniCluster

restartLeadingJobManager

public void restartLeadingJobManager()

restartTaskManager

public void restartTaskManager(int index)

start

public void start()

Overrides:

start in class FlinkMiniCluster

stop

public void stop()

Overrides:

stop in class FlinkMiniCluster

waitForTaskManagersToBeRegisteredAtJobManager

public void waitForTaskManagersToBeRegisteredAtJobManager(akka.actor.ActorRef jobManager)