Package org.apache.drill.yarn.appMaster

Class AbstractDrillbitScheduler.DrillbitManager

java.lang.Object

org.apache.drill.yarn.appMaster.AbstractTaskManager

org.apache.drill.yarn.appMaster.AbstractDrillbitScheduler.DrillbitManager

All Implemented Interfaces:

Scheduler.TaskManager

Enclosing class:

AbstractDrillbitScheduler

public class AbstractDrillbitScheduler.DrillbitManager
extends AbstractTaskManager

Interface to provide Drill-bit specific behavior. Ideally, this class would provide the interface to gracefully shut down a Drillbit, but Drill has no API to do graceful shutdown in this release. (The only graceful shutdown is by issuing a SIGTERM from the node runing the Drillbit, but YARN has no way to do this, despite active discussions on several YARN JIRA entries.

Constructor Summary

Constructors

Constructor	Description
DrillbitManager()

Method Summary

Modifier and Type	Method	Description
void	allocated(EventContext context)
void	completed(EventContext context)
boolean	isLive(EventContext context)
int	maxConcurrentAllocs()	Allow only one concurrent container request by default to ensure that the node blacklist mechanism works to ensure that the RM does not allocate two containers on the same node.

Methods inherited from class org.apache.drill.yarn.appMaster.AbstractTaskManager

getLaunchSpec, stop

Methods inherited from class java.lang.Object

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

Constructor Details

DrillbitManager

public DrillbitManager()

Method Details

maxConcurrentAllocs

public int maxConcurrentAllocs()

Allow only one concurrent container request by default to ensure that the node blacklist mechanism works to ensure that the RM does not allocate two containers on the same node.

Specified by:

maxConcurrentAllocs in interface Scheduler.TaskManager

Overrides:

maxConcurrentAllocs in class AbstractTaskManager

allocated

public void allocated(EventContext context)

Specified by:

allocated in interface Scheduler.TaskManager

Overrides:

allocated in class AbstractTaskManager

completed

public void completed(EventContext context)

Specified by:

completed in interface Scheduler.TaskManager

Overrides:

completed in class AbstractTaskManager

isLive

public boolean isLive(EventContext context)

Specified by:

isLive in interface Scheduler.TaskManager

Overrides:

isLive in class AbstractTaskManager