public abstract class AbstractYarnFlinkApplicationMasterRunner extends Object
JobMaster
and YarnResourceManager
.
The JobMasters handles Flink job execution, while the YarnResourceManager handles container
allocation and failure detection.Modifier and Type | Field and Description |
---|---|
protected String |
appMasterHostname
The host name passed by env
|
protected static Map<String,String> |
ENV
The process environment variables
|
protected static int |
INIT_ERROR_EXIT_CODE
The exit code returned if the initialization of the application master failed
|
protected static org.slf4j.Logger |
LOG
Logger
|
Constructor and Description |
---|
AbstractYarnFlinkApplicationMasterRunner() |
Modifier and Type | Method and Description |
---|---|
protected int |
run(String[] args)
The instance entry point for the YARN application master.
|
protected abstract int |
runApplicationMaster(Configuration config)
The main work method, must run as a privileged action.
|
protected static final org.slf4j.Logger LOG
protected static final int INIT_ERROR_EXIT_CODE
protected String appMasterHostname
public AbstractYarnFlinkApplicationMasterRunner()
protected int run(String[] args)
runApplicationMaster(org.apache.flink.configuration.Configuration)
as a
privileged action.args
- The command line arguments.protected abstract int runApplicationMaster(Configuration config)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.