Package org.apache.hadoop.yarn.server.router.clientrm

Class ApplicationSubmissionContextInterceptor

java.lang.Object

org.apache.hadoop.yarn.server.router.clientrm.AbstractClientRequestInterceptor

org.apache.hadoop.yarn.server.router.clientrm.PassThroughClientRequestInterceptor

org.apache.hadoop.yarn.server.router.clientrm.ApplicationSubmissionContextInterceptor

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.yarn.api.ApplicationBaseProtocol, org.apache.hadoop.yarn.api.ApplicationClientProtocol, ClientRequestInterceptor

public class ApplicationSubmissionContextInterceptor
extends PassThroughClientRequestInterceptor

It prevents DoS attack over the ApplicationClientProtocol. Currently, it checks the size of the ApplicationSubmissionContext. If it exceeds the limit it can cause Zookeeper failures.

Field Summary

Fields inherited from class org.apache.hadoop.yarn.server.router.clientrm.AbstractClientRequestInterceptor

user

Constructor Summary

Constructors

Constructor	Description
ApplicationSubmissionContextInterceptor()

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationResponse	submitApplication(org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationRequest request)

Methods inherited from class org.apache.hadoop.yarn.server.router.clientrm.PassThroughClientRequestInterceptor

cancelDelegationToken, deleteReservation, failApplicationAttempt, forceKillApplication, getApplicationAttemptReport, getApplicationAttempts, getApplicationReport, getApplications, getAttributesToNodes, getClusterMetrics, getClusterNodeAttributes, getClusterNodeLabels, getClusterNodes, getContainerReport, getContainers, getDelegationToken, getLabelsToNodes, getNewApplication, getNewReservation, getNodesToAttributes, getNodeToLabels, getQueueInfo, getQueueUserAcls, getResourceProfile, getResourceProfiles, getResourceTypeInfo, listReservations, moveApplicationAcrossQueues, renewDelegationToken, signalToContainer, submitReservation, updateApplicationPriority, updateApplicationTimeouts, updateReservation

Methods inherited from class org.apache.hadoop.yarn.server.router.clientrm.AbstractClientRequestInterceptor

getConf, getNextInterceptor, getTokenSecretManager, init, setConf, setNextInterceptor, setTokenSecretManager, shutdown

Methods inherited from class java.lang.Object

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

Constructor Details

ApplicationSubmissionContextInterceptor

public ApplicationSubmissionContextInterceptor()

Method Details

submitApplication

public org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationResponse submitApplication(org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationRequest request)
                                                                                       throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

submitApplication in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Overrides:

submitApplication in class PassThroughClientRequestInterceptor

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException