public class YarnTaskExecutorRunner extends Object
Modifier and Type | Field and Description |
---|---|
protected static org.slf4j.Logger |
LOG
Logger
|
Constructor and Description |
---|
YarnTaskExecutorRunner() |
Modifier and Type | Method and Description |
---|---|
static void |
main(String[] args)
The entry point for the YARN task executor runner.
|
protected int |
run(String[] args)
The instance entry point for the YARN task executor.
|
protected int |
runTaskExecutor(Configuration config)
The main work method, must run as a privileged action.
|
protected void |
shutdown() |
public static void main(String[] args)
args
- The command line arguments.protected int run(String[] args)
runTaskExecutor(org.apache.flink.configuration.Configuration)
as a
privileged action.args
- The command line arguments.protected int runTaskExecutor(Configuration config)
protected void shutdown()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.