org.apache.flink.runtime.yarn

Class AbstractFlinkYarnCluster

java.lang.Object

org.apache.flink.runtime.yarn.AbstractFlinkYarnCluster

public abstract class AbstractFlinkYarnCluster
extends Object

Constructor Summary

Constructors

Constructor and Description
AbstractFlinkYarnCluster()

Method Summary

Modifier and Type	Method and Description
abstract void	connectToCluster() Connect the FlinkYarnCluster to the ApplicationMaster.
abstract void	disconnect() Disconnect from the ApplicationMaster without stopping the session (therefore, use the shutdown() method.
abstract String	getApplicationId()
abstract FlinkYarnClusterStatus	getClusterStatus()
abstract String	getDiagnostics()
abstract InetSocketAddress	getJobManagerAddress()
abstract List<String>	getNewMessages()
abstract String	getWebInterfaceURL()
abstract boolean	hasBeenStopped()
abstract boolean	hasFailed()
abstract boolean	isDetached()
abstract void	shutdown(boolean failApplication)
abstract void	stopAfterJob(org.apache.flink.api.common.JobID jobID) Tells the ApplicationMaster to monitor the status of JobId and stop itself once the specified job has finished.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractFlinkYarnCluster

public AbstractFlinkYarnCluster()

Method Detail

getJobManagerAddress

public abstract InetSocketAddress getJobManagerAddress()

getWebInterfaceURL

public abstract String getWebInterfaceURL()

shutdown

public abstract void shutdown(boolean failApplication)

hasBeenStopped

public abstract boolean hasBeenStopped()

getClusterStatus

public abstract FlinkYarnClusterStatus getClusterStatus()

hasFailed

public abstract boolean hasFailed()

getDiagnostics

public abstract String getDiagnostics()

Returns:

Diagnostics if the Cluster is in "failed" state.

getNewMessages

public abstract List<String> getNewMessages()

getApplicationId

public abstract String getApplicationId()

isDetached

public abstract boolean isDetached()

connectToCluster

public abstract void connectToCluster()
                               throws IOException

Connect the FlinkYarnCluster to the ApplicationMaster. Detached YARN sessions don't need to connect to the ApplicationMaster. Detached per job YARN sessions need to connect until the required number of TaskManagers have been started.

Throws:

IOException

disconnect

public abstract void disconnect()

Disconnect from the ApplicationMaster without stopping the session (therefore, use the shutdown() method.

stopAfterJob

public abstract void stopAfterJob(org.apache.flink.api.common.JobID jobID)

Tells the ApplicationMaster to monitor the status of JobId and stop itself once the specified job has finished.

Parameters:

jobID -