private class LocalTaskEventHandler implements EventHandler<LocalTaskEvent> {
@Override
public void handle(LocalTaskEvent event) {
TajoContainerProxy proxy = (TajoContainerProxy) resourceAllocator.getContainers().get(event.getContainerId());
if (proxy != null) {
proxy.killTaskAttempt(event.getTaskAttemptId());
}
}
}
private class QueryFinishEventHandler implements EventHandler<QueryMasterQueryCompletedEvent> {