| /** |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| package org.apache.hadoop.yarn.api; |
| import java.io.IOException; |
| import java.lang.reflect.Array; |
| import java.lang.reflect.Constructor; |
| import java.lang.reflect.Method; |
| import java.lang.reflect.Modifier; |
| import java.lang.reflect.ParameterizedType; |
| import java.lang.reflect.Type; |
| import java.nio.ByteBuffer; |
| import java.util.EnumSet; |
| import java.util.HashMap; |
| import java.util.Iterator; |
| import java.util.List; |
| import java.util.Map; |
| import java.util.Map.Entry; |
| import java.util.Random; |
| import java.util.Set; |
| |
| import org.apache.commons.lang.math.LongRange; |
| import org.apache.commons.logging.Log; |
| import org.apache.commons.logging.LogFactory; |
| import org.apache.hadoop.security.proto.SecurityProtos.CancelDelegationTokenRequestProto; |
| import org.apache.hadoop.security.proto.SecurityProtos.CancelDelegationTokenResponseProto; |
| import org.apache.hadoop.security.proto.SecurityProtos.GetDelegationTokenRequestProto; |
| import org.apache.hadoop.security.proto.SecurityProtos.GetDelegationTokenResponseProto; |
| import org.apache.hadoop.security.proto.SecurityProtos.RenewDelegationTokenRequestProto; |
| import org.apache.hadoop.security.proto.SecurityProtos.RenewDelegationTokenResponseProto; |
| import org.apache.hadoop.security.proto.SecurityProtos.TokenProto; |
| import org.apache.hadoop.yarn.api.protocolrecords.StartContainerRequest; |
| import org.apache.hadoop.yarn.api.protocolrecords.IncreaseContainersResourceRequest; |
| import org.apache.hadoop.yarn.api.protocolrecords.IncreaseContainersResourceResponse; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.AllocateRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.AllocateResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.CancelDelegationTokenRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.CancelDelegationTokenResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.FinishApplicationMasterRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.FinishApplicationMasterResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetApplicationAttemptReportRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetApplicationAttemptReportResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetApplicationAttemptsRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetApplicationAttemptsResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetApplicationReportRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetApplicationReportResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetApplicationsRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetApplicationsResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetClusterMetricsRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetClusterMetricsResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetClusterNodeLabelsRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetClusterNodeLabelsResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetClusterNodesRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetClusterNodesResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetContainerReportRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetContainerReportResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetContainerStatusesRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetContainerStatusesResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetContainersRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetContainersResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetDelegationTokenRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetDelegationTokenResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetLabelsToNodesRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetLabelsToNodesResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetNewApplicationRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetNewApplicationResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetNodesToLabelsRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetNodesToLabelsResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetQueueInfoRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetQueueInfoResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetQueueUserAclsInfoRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.GetQueueUserAclsInfoResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.KillApplicationRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.KillApplicationResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.MoveApplicationAcrossQueuesRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.MoveApplicationAcrossQueuesResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.RegisterApplicationMasterRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.RegisterApplicationMasterResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.RenewDelegationTokenRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.RenewDelegationTokenResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.ReservationDeleteRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.ReservationDeleteResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.ReservationListRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.ReservationListResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.ReservationSubmissionRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.ReservationSubmissionResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.ReservationUpdateRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.ReservationUpdateResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.StartContainerRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.StartContainersRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.StartContainersResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.StopContainersRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.StopContainersResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.IncreaseContainersResourceRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.IncreaseContainersResourceResponsePBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.SubmitApplicationRequestPBImpl; |
| import org.apache.hadoop.yarn.api.protocolrecords.impl.pb.SubmitApplicationResponsePBImpl; |
| import org.apache.hadoop.yarn.api.records.ApplicationAttemptId; |
| import org.apache.hadoop.yarn.api.records.ApplicationAttemptReport; |
| import org.apache.hadoop.yarn.api.records.ApplicationId; |
| import org.apache.hadoop.yarn.api.records.ApplicationReport; |
| import org.apache.hadoop.yarn.api.records.ApplicationResourceUsageReport; |
| import org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext; |
| import org.apache.hadoop.yarn.api.records.Container; |
| import org.apache.hadoop.yarn.api.records.ContainerId; |
| import org.apache.hadoop.yarn.api.records.ContainerLaunchContext; |
| import org.apache.hadoop.yarn.api.records.ContainerReport; |
| import org.apache.hadoop.yarn.api.records.ContainerResourceChangeRequest; |
| import org.apache.hadoop.yarn.api.records.ContainerRetryContext; |
| import org.apache.hadoop.yarn.api.records.ContainerStatus; |
| import org.apache.hadoop.yarn.api.records.ExecutionTypeRequest; |
| import org.apache.hadoop.yarn.api.records.LocalResource; |
| import org.apache.hadoop.yarn.api.records.LogAggregationContext; |
| import org.apache.hadoop.yarn.api.records.NMToken; |
| import org.apache.hadoop.yarn.api.records.NodeId; |
| import org.apache.hadoop.yarn.api.records.NodeLabel; |
| import org.apache.hadoop.yarn.api.records.NodeReport; |
| import org.apache.hadoop.yarn.api.records.PreemptionContainer; |
| import org.apache.hadoop.yarn.api.records.PreemptionContract; |
| import org.apache.hadoop.yarn.api.records.PreemptionMessage; |
| import org.apache.hadoop.yarn.api.records.PreemptionResourceRequest; |
| import org.apache.hadoop.yarn.api.records.Priority; |
| import org.apache.hadoop.yarn.api.records.QueueInfo; |
| import org.apache.hadoop.yarn.api.records.QueueState; |
| import org.apache.hadoop.yarn.api.records.QueueStatistics; |
| import org.apache.hadoop.yarn.api.records.QueueUserACLInfo; |
| import org.apache.hadoop.yarn.api.records.ReservationAllocationState; |
| import org.apache.hadoop.yarn.api.records.ReservationDefinition; |
| import org.apache.hadoop.yarn.api.records.ReservationId; |
| import org.apache.hadoop.yarn.api.records.ReservationRequest; |
| import org.apache.hadoop.yarn.api.records.ReservationRequests; |
| import org.apache.hadoop.yarn.api.records.ResourceAllocationRequest; |
| import org.apache.hadoop.yarn.api.records.Resource; |
| import org.apache.hadoop.yarn.api.records.ResourceBlacklistRequest; |
| import org.apache.hadoop.yarn.api.records.ResourceOption; |
| import org.apache.hadoop.yarn.api.records.ResourceRequest; |
| import org.apache.hadoop.yarn.api.records.ResourceUtilization; |
| import org.apache.hadoop.yarn.api.records.SerializedException; |
| import org.apache.hadoop.yarn.api.records.StrictPreemptionContract; |
| import org.apache.hadoop.yarn.api.records.Token; |
| import org.apache.hadoop.yarn.api.records.URL; |
| import org.apache.hadoop.yarn.api.records.YarnClusterMetrics; |
| import org.apache.hadoop.yarn.api.records.impl.pb.ApplicationAttemptIdPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.ApplicationAttemptReportPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.ApplicationIdPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.ApplicationReportPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.ApplicationResourceUsageReportPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.ApplicationSubmissionContextPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.ContainerIdPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.ContainerLaunchContextPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.ContainerPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.ContainerReportPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.ContainerResourceChangeRequestPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.ContainerRetryContextPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.ContainerStatusPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.LocalResourcePBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.NMTokenPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.NodeIdPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.NodeLabelPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.NodeReportPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.PreemptionContainerPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.PreemptionContractPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.PreemptionMessagePBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.PreemptionResourceRequestPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.PriorityPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.QueueInfoPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.QueueUserACLInfoPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.ResourceBlacklistRequestPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.ResourceOptionPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.ResourcePBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.ResourceRequestPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.SerializedExceptionPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.StrictPreemptionContractPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.TokenPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.URLPBImpl; |
| import org.apache.hadoop.yarn.api.records.impl.pb.YarnClusterMetricsPBImpl; |
| import org.apache.hadoop.yarn.proto.YarnProtos.ApplicationAttemptIdProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.ApplicationAttemptReportProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.ApplicationIdProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.ApplicationReportProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.ApplicationResourceUsageReportProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.ApplicationSubmissionContextProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.ContainerIdProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.ContainerLaunchContextProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.ContainerProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.ContainerReportProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.ContainerResourceChangeRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.ContainerRetryContextProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.ContainerStatusProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.LocalResourceProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.NodeIdProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.NodeLabelProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.NodeReportProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.PreemptionContainerProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.PreemptionContractProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.PreemptionMessageProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.PreemptionResourceRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.PriorityProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.QueueInfoProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.QueueUserACLInfoProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.ResourceBlacklistRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.ResourceOptionProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.ResourceProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.ResourceRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.SerializedExceptionProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.StrictPreemptionContractProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.URLProto; |
| import org.apache.hadoop.yarn.proto.YarnProtos.YarnClusterMetricsProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.AddToClusterNodeLabelsRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.AddToClusterNodeLabelsResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.CheckForDecommissioningNodesRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.CheckForDecommissioningNodesResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshAdminAclsRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshAdminAclsResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshNodesRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshNodesResourcesRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshNodesResourcesResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshNodesResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshQueuesRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshQueuesResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshServiceAclsRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshServiceAclsResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshSuperUserGroupsConfigurationRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshSuperUserGroupsConfigurationResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshUserToGroupsMappingsRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshUserToGroupsMappingsResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RemoveFromClusterNodeLabelsRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RemoveFromClusterNodeLabelsResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.ReplaceLabelsOnNodeRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.ReplaceLabelsOnNodeResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.UpdateNodeResourceRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.UpdateNodeResourceResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.FinishApplicationMasterRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.FinishApplicationMasterResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetApplicationAttemptReportRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetApplicationAttemptReportResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetApplicationAttemptsRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetApplicationAttemptsResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetApplicationReportRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetApplicationReportResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetApplicationsRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetApplicationsResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetClusterMetricsRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetClusterMetricsResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetClusterNodeLabelsRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetClusterNodeLabelsResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetClusterNodesRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetClusterNodesResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetContainerReportRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetContainerReportResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetContainerStatusesRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetContainerStatusesResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetContainersRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetContainersResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetLabelsToNodesRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetLabelsToNodesResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetNewApplicationRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetNewApplicationResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetNodesToLabelsRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetNodesToLabelsResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetQueueInfoRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetQueueInfoResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetQueueUserAclsInfoRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetQueueUserAclsInfoResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.KillApplicationRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.KillApplicationResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.MoveApplicationAcrossQueuesRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.MoveApplicationAcrossQueuesResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.NMTokenProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.RegisterApplicationMasterRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.RegisterApplicationMasterResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.ReservationDeleteRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.ReservationDeleteResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.ReservationListRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.ReservationListResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.ReservationSubmissionRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.ReservationSubmissionResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.ReservationUpdateRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.ReservationUpdateResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.IncreaseContainersResourceRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.IncreaseContainersResourceResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.StartContainerRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.StartContainersRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.StartContainersResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.StopContainersRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.StopContainersResponseProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.SubmitApplicationRequestProto; |
| import org.apache.hadoop.yarn.proto.YarnServiceProtos.SubmitApplicationResponseProto; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.AddToClusterNodeLabelsRequestPBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.AddToClusterNodeLabelsResponsePBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.CheckForDecommissioningNodesRequestPBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.CheckForDecommissioningNodesResponsePBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RefreshAdminAclsRequestPBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RefreshAdminAclsResponsePBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RefreshNodesRequestPBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RefreshNodesResourcesRequestPBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RefreshNodesResourcesResponsePBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RefreshNodesResponsePBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RefreshQueuesRequestPBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RefreshQueuesResponsePBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RefreshServiceAclsRequestPBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RefreshServiceAclsResponsePBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RefreshSuperUserGroupsConfigurationRequestPBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RefreshSuperUserGroupsConfigurationResponsePBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RefreshUserToGroupsMappingsRequestPBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RefreshUserToGroupsMappingsResponsePBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RemoveFromClusterNodeLabelsRequestPBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RemoveFromClusterNodeLabelsResponsePBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.ReplaceLabelsOnNodeRequestPBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.ReplaceLabelsOnNodeResponsePBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.UpdateNodeResourceRequestPBImpl; |
| import org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.UpdateNodeResourceResponsePBImpl; |
| import org.apache.hadoop.yarn.util.resource.Resources; |
| import org.junit.Assert; |
| import org.junit.BeforeClass; |
| import org.junit.Ignore; |
| import org.junit.Test; |
| |
| import com.google.common.collect.ImmutableSet; |
| import com.google.common.collect.Lists; |
| import com.google.common.collect.Maps; |
| import com.google.common.collect.Sets; |
| |
| public class TestPBImplRecords { |
| static final Log LOG = LogFactory.getLog(TestPBImplRecords.class); |
| |
| private static HashMap<Type, Object> typeValueCache = new HashMap<Type, Object>(); |
| private static Random rand = new Random(); |
| private static byte [] bytes = new byte[] {'1', '2', '3', '4'}; |
| |
| @SuppressWarnings({"rawtypes", "unchecked"}) |
| private static Object genTypeValue(Type type) { |
| Object ret = typeValueCache.get(type); |
| if (ret != null) { |
| return ret; |
| } |
| // only use positive primitive values |
| if (type.equals(boolean.class)) { |
| return rand.nextBoolean(); |
| } else if (type.equals(byte.class)) { |
| return bytes[rand.nextInt(4)]; |
| } else if (type.equals(int.class) || type.equals(Integer.class)) { |
| return rand.nextInt(1000000); |
| } else if (type.equals(long.class)) { |
| return Long.valueOf(rand.nextInt(1000000)); |
| } else if (type.equals(float.class)) { |
| return rand.nextFloat(); |
| } else if (type.equals(double.class)) { |
| return rand.nextDouble(); |
| } else if (type.equals(String.class)) { |
| return String.format("%c%c%c", |
| 'a' + rand.nextInt(26), |
| 'a' + rand.nextInt(26), |
| 'a' + rand.nextInt(26)); |
| } else if (type instanceof Class) { |
| Class clazz = (Class)type; |
| if (clazz.isArray()) { |
| Class compClass = clazz.getComponentType(); |
| if (compClass != null) { |
| ret = Array.newInstance(compClass, 2); |
| Array.set(ret, 0, genTypeValue(compClass)); |
| Array.set(ret, 1, genTypeValue(compClass)); |
| } |
| } else if (clazz.isEnum()) { |
| Object [] values = clazz.getEnumConstants(); |
| ret = values[rand.nextInt(values.length)]; |
| } else if (clazz.equals(ByteBuffer.class)) { |
| // return new ByteBuffer every time |
| // to prevent potential side effects |
| ByteBuffer buff = ByteBuffer.allocate(4); |
| rand.nextBytes(buff.array()); |
| return buff; |
| } |
| } else if (type instanceof ParameterizedType) { |
| ParameterizedType pt = (ParameterizedType)type; |
| Type rawType = pt.getRawType(); |
| Type [] params = pt.getActualTypeArguments(); |
| // only support EnumSet<T>, List<T>, Set<T>, Map<K,V> |
| if (rawType.equals(EnumSet.class)) { |
| if (params[0] instanceof Class) { |
| Class c = (Class)(params[0]); |
| return EnumSet.allOf(c); |
| } |
| } if (rawType.equals(List.class)) { |
| ret = Lists.newArrayList(genTypeValue(params[0])); |
| } else if (rawType.equals(Set.class)) { |
| ret = Sets.newHashSet(genTypeValue(params[0])); |
| } else if (rawType.equals(Map.class)) { |
| Map<Object, Object> map = Maps.newHashMap(); |
| map.put(genTypeValue(params[0]), genTypeValue(params[1])); |
| ret = map; |
| } |
| } |
| if (ret == null) { |
| throw new IllegalArgumentException("type " + type + " is not supported"); |
| } |
| typeValueCache.put(type, ret); |
| return ret; |
| } |
| |
| /** |
| * this method generate record instance by calling newIntance |
| * using reflection, add register the generated value to typeValueCache |
| */ |
| @SuppressWarnings("rawtypes") |
| private static Object generateByNewInstance(Class clazz) throws Exception { |
| Object ret = typeValueCache.get(clazz); |
| if (ret != null) { |
| return ret; |
| } |
| Method newInstance = null; |
| Type [] paramTypes = new Type[0]; |
| // get newInstance method with most parameters |
| for (Method m : clazz.getMethods()) { |
| int mod = m.getModifiers(); |
| if (m.getDeclaringClass().equals(clazz) && |
| Modifier.isPublic(mod) && |
| Modifier.isStatic(mod) && |
| m.getName().equals("newInstance")) { |
| Type [] pts = m.getGenericParameterTypes(); |
| if (newInstance == null |
| || (pts.length > paramTypes.length)) { |
| newInstance = m; |
| paramTypes = pts; |
| } |
| } |
| } |
| if (newInstance == null) { |
| throw new IllegalArgumentException("type " + clazz.getName() + |
| " does not have newInstance method"); |
| } |
| Object [] args = new Object[paramTypes.length]; |
| for (int i=0;i<args.length;i++) { |
| args[i] = genTypeValue(paramTypes[i]); |
| } |
| ret = newInstance.invoke(null, args); |
| typeValueCache.put(clazz, ret); |
| return ret; |
| } |
| |
| @BeforeClass |
| public static void setup() throws Exception { |
| typeValueCache.put(LongRange.class, new LongRange(1000, 2000)); |
| typeValueCache.put(URL.class, URL.newInstance( |
| "http", "localhost", 8080, "file0")); |
| typeValueCache.put(SerializedException.class, |
| SerializedException.newInstance(new IOException("exception for test"))); |
| generateByNewInstance(ExecutionTypeRequest.class); |
| generateByNewInstance(LogAggregationContext.class); |
| generateByNewInstance(ApplicationId.class); |
| generateByNewInstance(ApplicationAttemptId.class); |
| generateByNewInstance(ContainerId.class); |
| generateByNewInstance(Resource.class); |
| generateByNewInstance(ResourceBlacklistRequest.class); |
| generateByNewInstance(ResourceOption.class); |
| generateByNewInstance(LocalResource.class); |
| generateByNewInstance(Priority.class); |
| generateByNewInstance(NodeId.class); |
| generateByNewInstance(NodeReport.class); |
| generateByNewInstance(Token.class); |
| generateByNewInstance(NMToken.class); |
| generateByNewInstance(ResourceRequest.class); |
| generateByNewInstance(ApplicationAttemptReport.class); |
| generateByNewInstance(ApplicationResourceUsageReport.class); |
| generateByNewInstance(ApplicationReport.class); |
| generateByNewInstance(Container.class); |
| generateByNewInstance(ContainerRetryContext.class); |
| generateByNewInstance(ContainerLaunchContext.class); |
| generateByNewInstance(ApplicationSubmissionContext.class); |
| generateByNewInstance(ContainerReport.class); |
| generateByNewInstance(ContainerResourceChangeRequest.class); |
| generateByNewInstance(IncreaseContainersResourceRequest.class); |
| generateByNewInstance(IncreaseContainersResourceResponse.class); |
| generateByNewInstance(ContainerStatus.class); |
| generateByNewInstance(PreemptionContainer.class); |
| generateByNewInstance(PreemptionResourceRequest.class); |
| generateByNewInstance(PreemptionContainer.class); |
| generateByNewInstance(PreemptionContract.class); |
| generateByNewInstance(StrictPreemptionContract.class); |
| generateByNewInstance(PreemptionMessage.class); |
| generateByNewInstance(StartContainerRequest.class); |
| generateByNewInstance(NodeLabel.class); |
| // genByNewInstance does not apply to QueueInfo, cause |
| // it is recursive(has sub queues) |
| typeValueCache.put(QueueInfo.class, QueueInfo.newInstance("root", 1.0f, |
| 1.0f, 0.1f, null, null, QueueState.RUNNING, ImmutableSet.of("x", "y"), |
| "x && y", null, false)); |
| generateByNewInstance(QueueStatistics.class); |
| generateByNewInstance(QueueUserACLInfo.class); |
| generateByNewInstance(YarnClusterMetrics.class); |
| // for reservation system |
| generateByNewInstance(ReservationId.class); |
| generateByNewInstance(ReservationRequest.class); |
| generateByNewInstance(ReservationRequests.class); |
| generateByNewInstance(ReservationDefinition.class); |
| generateByNewInstance(ResourceAllocationRequest.class); |
| generateByNewInstance(ReservationAllocationState.class); |
| generateByNewInstance(ResourceUtilization.class); |
| } |
| |
| private class GetSetPair { |
| public String propertyName; |
| public Method getMethod; |
| public Method setMethod; |
| public Type type; |
| public Object testValue; |
| |
| @Override |
| public String toString() { |
| return String.format("{ name=%s, class=%s, value=%s }", propertyName, |
| type, testValue); |
| } |
| } |
| |
| private <R> Map<String, GetSetPair> getGetSetPairs(Class<R> recordClass) |
| throws Exception { |
| Map<String, GetSetPair> ret = new HashMap<String, GetSetPair>(); |
| Method [] methods = recordClass.getDeclaredMethods(); |
| // get all get methods |
| for (int i = 0; i < methods.length; i++) { |
| Method m = methods[i]; |
| int mod = m.getModifiers(); |
| if (m.getDeclaringClass().equals(recordClass) && |
| Modifier.isPublic(mod) && |
| (!Modifier.isStatic(mod))) { |
| String name = m.getName(); |
| if (name.equals("getProto")) { |
| continue; |
| } |
| if ((name.length() > 3) && name.startsWith("get") && |
| (m.getParameterTypes().length == 0)) { |
| String propertyName = name.substring(3); |
| Type valueType = m.getGenericReturnType(); |
| GetSetPair p = ret.get(propertyName); |
| if (p == null) { |
| p = new GetSetPair(); |
| p.propertyName = propertyName; |
| p.type = valueType; |
| p.getMethod = m; |
| ret.put(propertyName, p); |
| } else { |
| Assert.fail("Multiple get method with same name: " + recordClass |
| + p.propertyName); |
| } |
| } |
| } |
| } |
| // match get methods with set methods |
| for (int i = 0; i < methods.length; i++) { |
| Method m = methods[i]; |
| int mod = m.getModifiers(); |
| if (m.getDeclaringClass().equals(recordClass) && |
| Modifier.isPublic(mod) && |
| (!Modifier.isStatic(mod))) { |
| String name = m.getName(); |
| if (name.startsWith("set") && (m.getParameterTypes().length == 1)) { |
| String propertyName = name.substring(3); |
| Type valueType = m.getGenericParameterTypes()[0]; |
| GetSetPair p = ret.get(propertyName); |
| if (p != null && p.type.equals(valueType)) { |
| p.setMethod = m; |
| } |
| } |
| } |
| } |
| // exclude incomplete get/set pair, and generate test value |
| Iterator<Entry<String, GetSetPair>> itr = ret.entrySet().iterator(); |
| while (itr.hasNext()) { |
| Entry<String, GetSetPair> cur = itr.next(); |
| GetSetPair gsp = cur.getValue(); |
| if ((gsp.getMethod == null) || |
| (gsp.setMethod == null)) { |
| LOG.info(String.format("Exclude protential property: %s\n", gsp.propertyName)); |
| itr.remove(); |
| } else { |
| LOG.info(String.format("New property: %s type: %s", gsp.toString(), gsp.type)); |
| gsp.testValue = genTypeValue(gsp.type); |
| LOG.info(String.format(" testValue: %s\n", gsp.testValue)); |
| } |
| } |
| return ret; |
| } |
| |
| private <R, P> void validatePBImplRecord(Class<R> recordClass, |
| Class<P> protoClass) |
| throws Exception { |
| LOG.info(String.format("Validate %s %s\n", recordClass.getName(), |
| protoClass.getName())); |
| Constructor<R> emptyConstructor = recordClass.getConstructor(); |
| Constructor<R> pbConstructor = recordClass.getConstructor(protoClass); |
| Method getProto = recordClass.getDeclaredMethod("getProto"); |
| Map<String, GetSetPair> getSetPairs = getGetSetPairs(recordClass); |
| R origRecord = emptyConstructor.newInstance(); |
| for (GetSetPair gsp : getSetPairs.values()) { |
| gsp.setMethod.invoke(origRecord, gsp.testValue); |
| } |
| Object ret = getProto.invoke(origRecord); |
| Assert.assertNotNull(recordClass.getName() + "#getProto returns null", ret); |
| if (!(protoClass.isAssignableFrom(ret.getClass()))) { |
| Assert.fail("Illegal getProto method return type: " + ret.getClass()); |
| } |
| R deserRecord = pbConstructor.newInstance(ret); |
| Assert.assertEquals("whole " + recordClass + " records should be equal", |
| origRecord, deserRecord); |
| for (GetSetPair gsp : getSetPairs.values()) { |
| Object origValue = gsp.getMethod.invoke(origRecord); |
| Object deserValue = gsp.getMethod.invoke(deserRecord); |
| Assert.assertEquals("property " + recordClass.getName() + "#" |
| + gsp.propertyName + " should be equal", origValue, deserValue); |
| } |
| } |
| |
| @Test |
| public void testAllocateRequestPBImpl() throws Exception { |
| validatePBImplRecord(AllocateRequestPBImpl.class, AllocateRequestProto.class); |
| } |
| |
| @Test |
| public void testAllocateResponsePBImpl() throws Exception { |
| validatePBImplRecord(AllocateResponsePBImpl.class, AllocateResponseProto.class); |
| } |
| |
| @Test |
| public void testCancelDelegationTokenRequestPBImpl() throws Exception { |
| validatePBImplRecord(CancelDelegationTokenRequestPBImpl.class, |
| CancelDelegationTokenRequestProto.class); |
| } |
| |
| @Test |
| public void testCancelDelegationTokenResponsePBImpl() throws Exception { |
| validatePBImplRecord(CancelDelegationTokenResponsePBImpl.class, |
| CancelDelegationTokenResponseProto.class); |
| } |
| |
| @Test |
| public void testFinishApplicationMasterRequestPBImpl() throws Exception { |
| validatePBImplRecord(FinishApplicationMasterRequestPBImpl.class, |
| FinishApplicationMasterRequestProto.class); |
| } |
| |
| @Test |
| public void testFinishApplicationMasterResponsePBImpl() throws Exception { |
| validatePBImplRecord(FinishApplicationMasterResponsePBImpl.class, |
| FinishApplicationMasterResponseProto.class); |
| } |
| |
| @Test |
| public void testGetApplicationAttemptReportRequestPBImpl() throws Exception { |
| validatePBImplRecord(GetApplicationAttemptReportRequestPBImpl.class, |
| GetApplicationAttemptReportRequestProto.class); |
| } |
| |
| @Test |
| public void testGetApplicationAttemptReportResponsePBImpl() throws Exception { |
| validatePBImplRecord(GetApplicationAttemptReportResponsePBImpl.class, |
| GetApplicationAttemptReportResponseProto.class); |
| } |
| |
| @Test |
| public void testGetApplicationAttemptsRequestPBImpl() throws Exception { |
| validatePBImplRecord(GetApplicationAttemptsRequestPBImpl.class, |
| GetApplicationAttemptsRequestProto.class); |
| } |
| |
| @Test |
| public void testGetApplicationAttemptsResponsePBImpl() throws Exception { |
| validatePBImplRecord(GetApplicationAttemptsResponsePBImpl.class, |
| GetApplicationAttemptsResponseProto.class); |
| } |
| |
| @Test |
| public void testGetApplicationReportRequestPBImpl() throws Exception { |
| validatePBImplRecord(GetApplicationReportRequestPBImpl.class, |
| GetApplicationReportRequestProto.class); |
| } |
| |
| @Test |
| public void testGetApplicationReportResponsePBImpl() throws Exception { |
| validatePBImplRecord(GetApplicationReportResponsePBImpl.class, |
| GetApplicationReportResponseProto.class); |
| } |
| |
| @Test |
| public void testGetApplicationsRequestPBImpl() throws Exception { |
| validatePBImplRecord(GetApplicationsRequestPBImpl.class, |
| GetApplicationsRequestProto.class); |
| } |
| |
| @Test |
| public void testGetApplicationsResponsePBImpl() throws Exception { |
| validatePBImplRecord(GetApplicationsResponsePBImpl.class, |
| GetApplicationsResponseProto.class); |
| } |
| |
| @Test |
| public void testGetClusterMetricsRequestPBImpl() throws Exception { |
| validatePBImplRecord(GetClusterMetricsRequestPBImpl.class, |
| GetClusterMetricsRequestProto.class); |
| } |
| |
| @Test |
| public void testGetClusterMetricsResponsePBImpl() throws Exception { |
| validatePBImplRecord(GetClusterMetricsResponsePBImpl.class, |
| GetClusterMetricsResponseProto.class); |
| } |
| |
| @Test |
| public void testGetClusterNodesRequestPBImpl() throws Exception { |
| validatePBImplRecord(GetClusterNodesRequestPBImpl.class, |
| GetClusterNodesRequestProto.class); |
| } |
| |
| @Test |
| public void testGetClusterNodesResponsePBImpl() throws Exception { |
| validatePBImplRecord(GetClusterNodesResponsePBImpl.class, |
| GetClusterNodesResponseProto.class); |
| } |
| |
| @Test |
| public void testGetContainerReportRequestPBImpl() throws Exception { |
| validatePBImplRecord(GetContainerReportRequestPBImpl.class, |
| GetContainerReportRequestProto.class); |
| } |
| |
| @Test |
| public void testGetContainerReportResponsePBImpl() throws Exception { |
| validatePBImplRecord(GetContainerReportResponsePBImpl.class, |
| GetContainerReportResponseProto.class); |
| } |
| |
| @Test |
| public void testGetContainersRequestPBImpl() throws Exception { |
| validatePBImplRecord(GetContainersRequestPBImpl.class, |
| GetContainersRequestProto.class); |
| } |
| |
| @Test |
| public void testGetContainersResponsePBImpl() throws Exception { |
| validatePBImplRecord(GetContainersResponsePBImpl.class, |
| GetContainersResponseProto.class); |
| } |
| |
| @Test |
| public void testGetContainerStatusesRequestPBImpl() throws Exception { |
| validatePBImplRecord(GetContainerStatusesRequestPBImpl.class, |
| GetContainerStatusesRequestProto.class); |
| } |
| |
| @Test |
| public void testGetContainerStatusesResponsePBImpl() throws Exception { |
| validatePBImplRecord(GetContainerStatusesResponsePBImpl.class, |
| GetContainerStatusesResponseProto.class); |
| } |
| |
| @Test |
| public void testGetDelegationTokenRequestPBImpl() throws Exception { |
| validatePBImplRecord(GetDelegationTokenRequestPBImpl.class, |
| GetDelegationTokenRequestProto.class); |
| } |
| |
| @Test |
| public void testGetDelegationTokenResponsePBImpl() throws Exception { |
| validatePBImplRecord(GetDelegationTokenResponsePBImpl.class, |
| GetDelegationTokenResponseProto.class); |
| } |
| |
| @Test |
| public void testGetNewApplicationRequestPBImpl() throws Exception { |
| validatePBImplRecord(GetNewApplicationRequestPBImpl.class, |
| GetNewApplicationRequestProto.class); |
| } |
| |
| @Test |
| public void testGetNewApplicationResponsePBImpl() throws Exception { |
| validatePBImplRecord(GetNewApplicationResponsePBImpl.class, |
| GetNewApplicationResponseProto.class); |
| } |
| |
| @Test |
| public void testGetQueueInfoRequestPBImpl() throws Exception { |
| validatePBImplRecord(GetQueueInfoRequestPBImpl.class, |
| GetQueueInfoRequestProto.class); |
| } |
| |
| @Test |
| public void testGetQueueInfoResponsePBImpl() throws Exception { |
| validatePBImplRecord(GetQueueInfoResponsePBImpl.class, |
| GetQueueInfoResponseProto.class); |
| } |
| |
| @Test |
| public void testGetQueueUserAclsInfoRequestPBImpl() throws Exception { |
| validatePBImplRecord(GetQueueUserAclsInfoRequestPBImpl.class, |
| GetQueueUserAclsInfoRequestProto.class); |
| } |
| |
| @Test |
| public void testGetQueueUserAclsInfoResponsePBImpl() throws Exception { |
| validatePBImplRecord(GetQueueUserAclsInfoResponsePBImpl.class, |
| GetQueueUserAclsInfoResponseProto.class); |
| } |
| |
| @Test |
| public void testKillApplicationRequestPBImpl() throws Exception { |
| validatePBImplRecord(KillApplicationRequestPBImpl.class, |
| KillApplicationRequestProto.class); |
| } |
| |
| @Test |
| public void testKillApplicationResponsePBImpl() throws Exception { |
| validatePBImplRecord(KillApplicationResponsePBImpl.class, |
| KillApplicationResponseProto.class); |
| } |
| |
| @Test |
| public void testMoveApplicationAcrossQueuesRequestPBImpl() throws Exception { |
| validatePBImplRecord(MoveApplicationAcrossQueuesRequestPBImpl.class, |
| MoveApplicationAcrossQueuesRequestProto.class); |
| } |
| |
| @Test |
| public void testMoveApplicationAcrossQueuesResponsePBImpl() throws Exception { |
| validatePBImplRecord(MoveApplicationAcrossQueuesResponsePBImpl.class, |
| MoveApplicationAcrossQueuesResponseProto.class); |
| } |
| |
| @Test |
| public void testRegisterApplicationMasterRequestPBImpl() throws Exception { |
| validatePBImplRecord(RegisterApplicationMasterRequestPBImpl.class, |
| RegisterApplicationMasterRequestProto.class); |
| } |
| |
| @Test |
| public void testRegisterApplicationMasterResponsePBImpl() throws Exception { |
| validatePBImplRecord(RegisterApplicationMasterResponsePBImpl.class, |
| RegisterApplicationMasterResponseProto.class); |
| } |
| |
| @Test |
| public void testRenewDelegationTokenRequestPBImpl() throws Exception { |
| validatePBImplRecord(RenewDelegationTokenRequestPBImpl.class, |
| RenewDelegationTokenRequestProto.class); |
| } |
| |
| @Test |
| public void testRenewDelegationTokenResponsePBImpl() throws Exception { |
| validatePBImplRecord(RenewDelegationTokenResponsePBImpl.class, |
| RenewDelegationTokenResponseProto.class); |
| } |
| |
| @Test |
| public void testStartContainerRequestPBImpl() throws Exception { |
| validatePBImplRecord(StartContainerRequestPBImpl.class, |
| StartContainerRequestProto.class); |
| } |
| |
| @Test |
| public void testStartContainersRequestPBImpl() throws Exception { |
| validatePBImplRecord(StartContainersRequestPBImpl.class, |
| StartContainersRequestProto.class); |
| } |
| |
| @Test |
| public void testStartContainersResponsePBImpl() throws Exception { |
| validatePBImplRecord(StartContainersResponsePBImpl.class, |
| StartContainersResponseProto.class); |
| } |
| |
| @Test |
| public void testStopContainersRequestPBImpl() throws Exception { |
| validatePBImplRecord(StopContainersRequestPBImpl.class, |
| StopContainersRequestProto.class); |
| } |
| |
| @Test |
| public void testStopContainersResponsePBImpl() throws Exception { |
| validatePBImplRecord(StopContainersResponsePBImpl.class, |
| StopContainersResponseProto.class); |
| } |
| |
| @Test |
| public void testIncreaseContainersResourceRequestPBImpl() throws Exception { |
| validatePBImplRecord(IncreaseContainersResourceRequestPBImpl.class, |
| IncreaseContainersResourceRequestProto.class); |
| } |
| |
| @Test |
| public void testIncreaseContainersResourceResponsePBImpl() throws Exception { |
| validatePBImplRecord(IncreaseContainersResourceResponsePBImpl.class, |
| IncreaseContainersResourceResponseProto.class); |
| } |
| |
| @Test |
| public void testSubmitApplicationRequestPBImpl() throws Exception { |
| validatePBImplRecord(SubmitApplicationRequestPBImpl.class, |
| SubmitApplicationRequestProto.class); |
| } |
| |
| @Test |
| public void testSubmitApplicationResponsePBImpl() throws Exception { |
| validatePBImplRecord(SubmitApplicationResponsePBImpl.class, |
| SubmitApplicationResponseProto.class); |
| } |
| |
| @Test |
| @Ignore |
| // ignore cause ApplicationIdPBImpl is immutable |
| public void testApplicationAttemptIdPBImpl() throws Exception { |
| validatePBImplRecord(ApplicationAttemptIdPBImpl.class, |
| ApplicationAttemptIdProto.class); |
| } |
| |
| @Test |
| public void testApplicationAttemptReportPBImpl() throws Exception { |
| validatePBImplRecord(ApplicationAttemptReportPBImpl.class, |
| ApplicationAttemptReportProto.class); |
| } |
| |
| @Test |
| @Ignore |
| // ignore cause ApplicationIdPBImpl is immutable |
| public void testApplicationIdPBImpl() throws Exception { |
| validatePBImplRecord(ApplicationIdPBImpl.class, ApplicationIdProto.class); |
| } |
| |
| @Test |
| public void testApplicationReportPBImpl() throws Exception { |
| validatePBImplRecord(ApplicationReportPBImpl.class, |
| ApplicationReportProto.class); |
| } |
| |
| @Test |
| public void testApplicationResourceUsageReportPBImpl() throws Exception { |
| validatePBImplRecord(ApplicationResourceUsageReportPBImpl.class, |
| ApplicationResourceUsageReportProto.class); |
| } |
| |
| @Test |
| public void testApplicationSubmissionContextPBImpl() throws Exception { |
| validatePBImplRecord(ApplicationSubmissionContextPBImpl.class, |
| ApplicationSubmissionContextProto.class); |
| |
| ApplicationSubmissionContext ctx = |
| ApplicationSubmissionContext.newInstance(null, null, null, null, null, |
| false, false, 0, Resources.none(), null, false, null, null); |
| |
| Assert.assertNotNull(ctx.getResource()); |
| } |
| |
| @Test |
| @Ignore |
| // ignore cause ApplicationIdPBImpl is immutable |
| public void testContainerIdPBImpl() throws Exception { |
| validatePBImplRecord(ContainerIdPBImpl.class, ContainerIdProto.class); |
| } |
| |
| @Test |
| public void testContainerRetryPBImpl() throws Exception { |
| validatePBImplRecord(ContainerRetryContextPBImpl.class, |
| ContainerRetryContextProto.class); |
| } |
| |
| @Test |
| public void testContainerLaunchContextPBImpl() throws Exception { |
| validatePBImplRecord(ContainerLaunchContextPBImpl.class, |
| ContainerLaunchContextProto.class); |
| } |
| |
| @Test |
| public void testContainerPBImpl() throws Exception { |
| validatePBImplRecord(ContainerPBImpl.class, ContainerProto.class); |
| } |
| |
| @Test |
| public void testContainerReportPBImpl() throws Exception { |
| validatePBImplRecord(ContainerReportPBImpl.class, ContainerReportProto.class); |
| } |
| |
| @Test |
| public void testContainerResourceChangeRequestPBImpl() throws Exception { |
| validatePBImplRecord(ContainerResourceChangeRequestPBImpl.class, |
| ContainerResourceChangeRequestProto.class); |
| } |
| |
| @Test |
| public void testContainerStatusPBImpl() throws Exception { |
| validatePBImplRecord(ContainerStatusPBImpl.class, ContainerStatusProto.class); |
| } |
| |
| @Test |
| public void testLocalResourcePBImpl() throws Exception { |
| validatePBImplRecord(LocalResourcePBImpl.class, LocalResourceProto.class); |
| } |
| |
| @Test |
| public void testNMTokenPBImpl() throws Exception { |
| validatePBImplRecord(NMTokenPBImpl.class, NMTokenProto.class); |
| } |
| |
| @Test |
| @Ignore |
| // ignore cause ApplicationIdPBImpl is immutable |
| public void testNodeIdPBImpl() throws Exception { |
| validatePBImplRecord(NodeIdPBImpl.class, NodeIdProto.class); |
| } |
| |
| @Test |
| public void testNodeReportPBImpl() throws Exception { |
| validatePBImplRecord(NodeReportPBImpl.class, NodeReportProto.class); |
| } |
| |
| @Test |
| public void testPreemptionContainerPBImpl() throws Exception { |
| validatePBImplRecord(PreemptionContainerPBImpl.class, |
| PreemptionContainerProto.class); |
| } |
| |
| @Test |
| public void testPreemptionContractPBImpl() throws Exception { |
| validatePBImplRecord(PreemptionContractPBImpl.class, |
| PreemptionContractProto.class); |
| } |
| |
| @Test |
| public void testPreemptionMessagePBImpl() throws Exception { |
| validatePBImplRecord(PreemptionMessagePBImpl.class, |
| PreemptionMessageProto.class); |
| } |
| |
| @Test |
| public void testPreemptionResourceRequestPBImpl() throws Exception { |
| validatePBImplRecord(PreemptionResourceRequestPBImpl.class, |
| PreemptionResourceRequestProto.class); |
| } |
| |
| @Test |
| public void testPriorityPBImpl() throws Exception { |
| validatePBImplRecord(PriorityPBImpl.class, PriorityProto.class); |
| } |
| |
| @Test |
| public void testQueueInfoPBImpl() throws Exception { |
| validatePBImplRecord(QueueInfoPBImpl.class, QueueInfoProto.class); |
| } |
| |
| @Test |
| public void testQueueUserACLInfoPBImpl() throws Exception { |
| validatePBImplRecord(QueueUserACLInfoPBImpl.class, |
| QueueUserACLInfoProto.class); |
| } |
| |
| @Test |
| public void testResourceBlacklistRequestPBImpl() throws Exception { |
| validatePBImplRecord(ResourceBlacklistRequestPBImpl.class, |
| ResourceBlacklistRequestProto.class); |
| } |
| |
| @Test |
| @Ignore |
| // ignore as ResourceOptionPBImpl is immutable |
| public void testResourceOptionPBImpl() throws Exception { |
| validatePBImplRecord(ResourceOptionPBImpl.class, ResourceOptionProto.class); |
| } |
| |
| @Test |
| public void testResourcePBImpl() throws Exception { |
| validatePBImplRecord(ResourcePBImpl.class, ResourceProto.class); |
| } |
| |
| @Test |
| public void testResourceRequestPBImpl() throws Exception { |
| validatePBImplRecord(ResourceRequestPBImpl.class, ResourceRequestProto.class); |
| } |
| |
| @Test |
| public void testSerializedExceptionPBImpl() throws Exception { |
| validatePBImplRecord(SerializedExceptionPBImpl.class, |
| SerializedExceptionProto.class); |
| } |
| |
| @Test |
| public void testStrictPreemptionContractPBImpl() throws Exception { |
| validatePBImplRecord(StrictPreemptionContractPBImpl.class, |
| StrictPreemptionContractProto.class); |
| } |
| |
| @Test |
| public void testTokenPBImpl() throws Exception { |
| validatePBImplRecord(TokenPBImpl.class, TokenProto.class); |
| } |
| |
| @Test |
| public void testURLPBImpl() throws Exception { |
| validatePBImplRecord(URLPBImpl.class, URLProto.class); |
| } |
| |
| @Test |
| public void testYarnClusterMetricsPBImpl() throws Exception { |
| validatePBImplRecord(YarnClusterMetricsPBImpl.class, |
| YarnClusterMetricsProto.class); |
| } |
| |
| @Test |
| public void testRefreshAdminAclsRequestPBImpl() throws Exception { |
| validatePBImplRecord(RefreshAdminAclsRequestPBImpl.class, |
| RefreshAdminAclsRequestProto.class); |
| } |
| |
| @Test |
| public void testRefreshAdminAclsResponsePBImpl() throws Exception { |
| validatePBImplRecord(RefreshAdminAclsResponsePBImpl.class, |
| RefreshAdminAclsResponseProto.class); |
| } |
| |
| @Test |
| public void testRefreshNodesRequestPBImpl() throws Exception { |
| validatePBImplRecord(RefreshNodesRequestPBImpl.class, |
| RefreshNodesRequestProto.class); |
| } |
| |
| @Test |
| public void testRefreshNodesResponsePBImpl() throws Exception { |
| validatePBImplRecord(RefreshNodesResponsePBImpl.class, |
| RefreshNodesResponseProto.class); |
| } |
| |
| @Test |
| public void testRefreshQueuesRequestPBImpl() throws Exception { |
| validatePBImplRecord(RefreshQueuesRequestPBImpl.class, |
| RefreshQueuesRequestProto.class); |
| } |
| |
| @Test |
| public void testRefreshQueuesResponsePBImpl() throws Exception { |
| validatePBImplRecord(RefreshQueuesResponsePBImpl.class, |
| RefreshQueuesResponseProto.class); |
| } |
| |
| @Test |
| public void testRefreshNodesResourcesRequestPBImpl() throws Exception { |
| validatePBImplRecord(RefreshNodesResourcesRequestPBImpl.class, |
| RefreshNodesResourcesRequestProto.class); |
| } |
| |
| @Test |
| public void testRefreshNodesResourcesResponsePBImpl() throws Exception { |
| validatePBImplRecord(RefreshNodesResourcesResponsePBImpl.class, |
| RefreshNodesResourcesResponseProto.class); |
| } |
| |
| @Test |
| public void testRefreshServiceAclsRequestPBImpl() throws Exception { |
| validatePBImplRecord(RefreshServiceAclsRequestPBImpl.class, |
| RefreshServiceAclsRequestProto.class); |
| } |
| |
| @Test |
| public void testRefreshServiceAclsResponsePBImpl() throws Exception { |
| validatePBImplRecord(RefreshServiceAclsResponsePBImpl.class, |
| RefreshServiceAclsResponseProto.class); |
| } |
| |
| @Test |
| public void testRefreshSuperUserGroupsConfigurationRequestPBImpl() |
| throws Exception { |
| validatePBImplRecord(RefreshSuperUserGroupsConfigurationRequestPBImpl.class, |
| RefreshSuperUserGroupsConfigurationRequestProto.class); |
| } |
| |
| @Test |
| public void testRefreshSuperUserGroupsConfigurationResponsePBImpl() |
| throws Exception { |
| validatePBImplRecord(RefreshSuperUserGroupsConfigurationResponsePBImpl.class, |
| RefreshSuperUserGroupsConfigurationResponseProto.class); |
| } |
| |
| @Test |
| public void testRefreshUserToGroupsMappingsRequestPBImpl() throws Exception { |
| validatePBImplRecord(RefreshUserToGroupsMappingsRequestPBImpl.class, |
| RefreshUserToGroupsMappingsRequestProto.class); |
| } |
| |
| @Test |
| public void testRefreshUserToGroupsMappingsResponsePBImpl() throws Exception { |
| validatePBImplRecord(RefreshUserToGroupsMappingsResponsePBImpl.class, |
| RefreshUserToGroupsMappingsResponseProto.class); |
| } |
| |
| @Test |
| public void testUpdateNodeResourceRequestPBImpl() throws Exception { |
| validatePBImplRecord(UpdateNodeResourceRequestPBImpl.class, |
| UpdateNodeResourceRequestProto.class); |
| } |
| |
| @Test |
| public void testUpdateNodeResourceResponsePBImpl() throws Exception { |
| validatePBImplRecord(UpdateNodeResourceResponsePBImpl.class, |
| UpdateNodeResourceResponseProto.class); |
| } |
| |
| @Test |
| public void testReservationSubmissionRequestPBImpl() throws Exception { |
| validatePBImplRecord(ReservationSubmissionRequestPBImpl.class, |
| ReservationSubmissionRequestProto.class); |
| } |
| |
| @Test |
| public void testReservationSubmissionResponsePBImpl() throws Exception { |
| validatePBImplRecord(ReservationSubmissionResponsePBImpl.class, |
| ReservationSubmissionResponseProto.class); |
| } |
| |
| @Test |
| public void testReservationUpdateRequestPBImpl() throws Exception { |
| validatePBImplRecord(ReservationUpdateRequestPBImpl.class, |
| ReservationUpdateRequestProto.class); |
| } |
| |
| @Test |
| public void testReservationUpdateResponsePBImpl() throws Exception { |
| validatePBImplRecord(ReservationUpdateResponsePBImpl.class, |
| ReservationUpdateResponseProto.class); |
| } |
| |
| @Test |
| public void testReservationDeleteRequestPBImpl() throws Exception { |
| validatePBImplRecord(ReservationDeleteRequestPBImpl.class, |
| ReservationDeleteRequestProto.class); |
| } |
| |
| @Test |
| public void testReservationDeleteResponsePBImpl() throws Exception { |
| validatePBImplRecord(ReservationDeleteResponsePBImpl.class, |
| ReservationDeleteResponseProto.class); |
| } |
| |
| @Test |
| public void testReservationListRequestPBImpl() throws Exception { |
| validatePBImplRecord(ReservationListRequestPBImpl.class, |
| ReservationListRequestProto.class); |
| } |
| |
| @Test |
| public void testReservationListResponsePBImpl() throws Exception { |
| validatePBImplRecord(ReservationListResponsePBImpl.class, |
| ReservationListResponseProto.class); |
| } |
| |
| @Test |
| public void testAddToClusterNodeLabelsRequestPBImpl() throws Exception { |
| validatePBImplRecord(AddToClusterNodeLabelsRequestPBImpl.class, |
| AddToClusterNodeLabelsRequestProto.class); |
| } |
| |
| @Test |
| public void testAddToClusterNodeLabelsResponsePBImpl() throws Exception { |
| validatePBImplRecord(AddToClusterNodeLabelsResponsePBImpl.class, |
| AddToClusterNodeLabelsResponseProto.class); |
| } |
| |
| @Test |
| public void testRemoveFromClusterNodeLabelsRequestPBImpl() throws Exception { |
| validatePBImplRecord(RemoveFromClusterNodeLabelsRequestPBImpl.class, |
| RemoveFromClusterNodeLabelsRequestProto.class); |
| } |
| |
| @Test |
| public void testRemoveFromClusterNodeLabelsResponsePBImpl() throws Exception { |
| validatePBImplRecord(RemoveFromClusterNodeLabelsResponsePBImpl.class, |
| RemoveFromClusterNodeLabelsResponseProto.class); |
| } |
| |
| @Test |
| public void testGetClusterNodeLabelsRequestPBImpl() throws Exception { |
| validatePBImplRecord(GetClusterNodeLabelsRequestPBImpl.class, |
| GetClusterNodeLabelsRequestProto.class); |
| } |
| |
| @Test |
| public void testGetClusterNodeLabelsResponsePBImpl() throws Exception { |
| validatePBImplRecord(GetClusterNodeLabelsResponsePBImpl.class, |
| GetClusterNodeLabelsResponseProto.class); |
| } |
| |
| @Test |
| public void testReplaceLabelsOnNodeRequestPBImpl() throws Exception { |
| validatePBImplRecord(ReplaceLabelsOnNodeRequestPBImpl.class, |
| ReplaceLabelsOnNodeRequestProto.class); |
| } |
| |
| @Test |
| public void testReplaceLabelsOnNodeResponsePBImpl() throws Exception { |
| validatePBImplRecord(ReplaceLabelsOnNodeResponsePBImpl.class, |
| ReplaceLabelsOnNodeResponseProto.class); |
| } |
| |
| @Test |
| public void testGetNodeToLabelsRequestPBImpl() throws Exception { |
| validatePBImplRecord(GetNodesToLabelsRequestPBImpl.class, |
| GetNodesToLabelsRequestProto.class); |
| } |
| |
| @Test |
| public void testGetNodeToLabelsResponsePBImpl() throws Exception { |
| validatePBImplRecord(GetNodesToLabelsResponsePBImpl.class, |
| GetNodesToLabelsResponseProto.class); |
| } |
| |
| @Test |
| public void testGetLabelsToNodesRequestPBImpl() throws Exception { |
| validatePBImplRecord(GetLabelsToNodesRequestPBImpl.class, |
| GetLabelsToNodesRequestProto.class); |
| } |
| |
| @Test |
| public void testGetLabelsToNodesResponsePBImpl() throws Exception { |
| validatePBImplRecord(GetLabelsToNodesResponsePBImpl.class, |
| GetLabelsToNodesResponseProto.class); |
| } |
| |
| @Test |
| public void testNodeLabelAttributesPBImpl() throws Exception { |
| validatePBImplRecord(NodeLabelPBImpl.class, |
| NodeLabelProto.class); |
| } |
| |
| @Test |
| public void testCheckForDecommissioningNodesRequestPBImpl() throws Exception { |
| validatePBImplRecord(CheckForDecommissioningNodesRequestPBImpl.class, |
| CheckForDecommissioningNodesRequestProto.class); |
| } |
| |
| @Test |
| public void testCheckForDecommissioningNodesResponsePBImpl() throws Exception { |
| validatePBImplRecord(CheckForDecommissioningNodesResponsePBImpl.class, |
| CheckForDecommissioningNodesResponseProto.class); |
| } |
| } |
