public abstract class AbstractFlinkYarnCluster extends Object
Constructor and Description |
---|
AbstractFlinkYarnCluster() |
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(boolean) method. |
abstract String |
getApplicationId()
Returns a string representation of the ApplicationID assigned by YARN.
|
abstract FlinkYarnClusterStatus |
getClusterStatus()
Returns the latest cluster status, with number of Taskmanagers and slots
|
abstract String |
getDiagnostics() |
abstract Configuration |
getFlinkConfiguration()
Return the Flink configuration object
|
abstract InetSocketAddress |
getJobManagerAddress()
Get hostname and port of the JobManager.
|
abstract List<String> |
getNewMessages()
May return new messages from the cluster.
|
abstract String |
getWebInterfaceURL()
Returns an URL (as a string) to the JobManager web interface, running next to the
ApplicationMaster and JobManager in a YARN container
|
abstract boolean |
hasBeenStopped()
Boolean indicating whether the cluster has been stopped already
|
abstract boolean |
hasFailed()
Boolean indicating whether the Flink YARN cluster is in an erronous state.
|
abstract boolean |
isDetached()
Flink's YARN cluster abstraction has two modes for connecting to the YARN AM.
|
abstract void |
shutdown(boolean failApplication)
Request the YARN cluster to shut down.
|
abstract void |
stopAfterJob(JobID jobID)
Tells the ApplicationMaster to monitor the status of JobId and stop itself once the specified
job has finished.
|
public abstract InetSocketAddress getJobManagerAddress()
public abstract String getWebInterfaceURL()
public abstract void shutdown(boolean failApplication)
failApplication
- If true, the application will be marked as failed in YARNpublic abstract boolean hasBeenStopped()
public abstract FlinkYarnClusterStatus getClusterStatus()
public abstract boolean hasFailed()
public abstract String getDiagnostics()
public abstract List<String> getNewMessages()
public abstract String getApplicationId()
public abstract boolean isDetached()
public abstract void connectToCluster() throws IOException
IOException
public abstract void disconnect()
shutdown(boolean)
method.shutdown(boolean)
public abstract void stopAfterJob(JobID jobID)
jobID
- Id of the jobpublic abstract Configuration getFlinkConfiguration()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.