Apache/hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

YARN-6379. Remove unused argument in ClientRMService. Contributed by Kai Sasaki.

Browse Source
This commit is contained in:
Akira Ajisaka 2017-03-27 11:23:41 +09:00
parent e7b7c96a30
commit b63ae854f9
No known key found for this signature in database
GPG Key ID: C1EDBB9CA400FD50
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/ClientRMService.java
View File

@ -1204,7 +1204,7 @@ public Server getServer() {
@Override @Override
public GetNewReservationResponse getNewReservation( public GetNewReservationResponse getNewReservation(
GetNewReservationRequest request) throws YarnException, IOException { GetNewReservationRequest request) throws YarnException, IOException {
checkReservationSystem(AuditConstants.CREATE_NEW_RESERVATION_REQUEST); checkReservationSystem();
GetNewReservationResponse response = GetNewReservationResponse response =
recordFactory.newRecordInstance(GetNewReservationResponse.class); recordFactory.newRecordInstance(GetNewReservationResponse.class);
@ -1218,7 +1218,7 @@ public GetNewReservationResponse getNewReservation(
public ReservationSubmissionResponse submitReservation( public ReservationSubmissionResponse submitReservation(
ReservationSubmissionRequest request) throws YarnException, IOException { ReservationSubmissionRequest request) throws YarnException, IOException {
// Check if reservation system is enabled // Check if reservation system is enabled
checkReservationSystem(AuditConstants.SUBMIT_RESERVATION_REQUEST); checkReservationSystem();
ReservationSubmissionResponse response = ReservationSubmissionResponse response =
recordFactory.newRecordInstance(ReservationSubmissionResponse.class); recordFactory.newRecordInstance(ReservationSubmissionResponse.class);
ReservationId reservationId = request.getReservationId(); ReservationId reservationId = request.getReservationId();
@ -1277,7 +1277,7 @@ public ReservationSubmissionResponse submitReservation(
public ReservationUpdateResponse updateReservation( public ReservationUpdateResponse updateReservation(
ReservationUpdateRequest request) throws YarnException, IOException { ReservationUpdateRequest request) throws YarnException, IOException {
// Check if reservation system is enabled // Check if reservation system is enabled
checkReservationSystem(AuditConstants.UPDATE_RESERVATION_REQUEST); checkReservationSystem();
ReservationUpdateResponse response = ReservationUpdateResponse response =
recordFactory.newRecordInstance(ReservationUpdateResponse.class); recordFactory.newRecordInstance(ReservationUpdateResponse.class);
// Validate the input // Validate the input
@ -1316,7 +1316,7 @@ public ReservationUpdateResponse updateReservation(
public ReservationDeleteResponse deleteReservation( public ReservationDeleteResponse deleteReservation(
ReservationDeleteRequest request) throws YarnException, IOException { ReservationDeleteRequest request) throws YarnException, IOException {
// Check if reservation system is enabled // Check if reservation system is enabled
checkReservationSystem(AuditConstants.DELETE_RESERVATION_REQUEST); checkReservationSystem();
ReservationDeleteResponse response = ReservationDeleteResponse response =
recordFactory.newRecordInstance(ReservationDeleteResponse.class); recordFactory.newRecordInstance(ReservationDeleteResponse.class);
// Validate the input // Validate the input
@ -1355,7 +1355,7 @@ public ReservationDeleteResponse deleteReservation(
public ReservationListResponse listReservations( public ReservationListResponse listReservations(
ReservationListRequest requestInfo) throws YarnException, IOException { ReservationListRequest requestInfo) throws YarnException, IOException {
// Check if reservation system is enabled // Check if reservation system is enabled
checkReservationSystem(AuditConstants.LIST_RESERVATION_REQUEST); checkReservationSystem();
ReservationListResponse response = ReservationListResponse response =
recordFactory.newRecordInstance(ReservationListResponse.class); recordFactory.newRecordInstance(ReservationListResponse.class);
@ -1418,7 +1418,7 @@ public GetClusterNodeLabelsResponse getClusterNodeLabels(
labelsMgr.getClusterNodeLabels()); labelsMgr.getClusterNodeLabels());
} }
private void checkReservationSystem(String auditConstant) private void checkReservationSystem()
throws YarnException { throws YarnException {
// Check if reservation is enabled // Check if reservation is enabled
if (reservationSystem == null) { if (reservationSystem == null) {