|
31 | 31 | import org.apache.hadoop.yarn.api.records.NodeAttributeType; |
32 | 32 | import org.apache.hadoop.yarn.conf.YarnConfiguration; |
33 | 33 | import org.apache.hadoop.yarn.exceptions.YarnException; |
34 | | -import org.apache.hadoop.yarn.server.api.protocolrecords.*; |
| 34 | +import org.apache.hadoop.yarn.server.api.protocolrecords.RefreshNodesRequest; |
| 35 | +import org.apache.hadoop.yarn.server.api.protocolrecords.RefreshQueuesRequest; |
| 36 | +import org.apache.hadoop.yarn.server.api.protocolrecords.RefreshQueuesResponse; |
| 37 | +import org.apache.hadoop.yarn.server.api.protocolrecords.RefreshSuperUserGroupsConfigurationRequest; |
| 38 | +import org.apache.hadoop.yarn.server.api.protocolrecords.RefreshSuperUserGroupsConfigurationResponse; |
| 39 | +import org.apache.hadoop.yarn.server.api.protocolrecords.RefreshUserToGroupsMappingsRequest; |
| 40 | +import org.apache.hadoop.yarn.server.api.protocolrecords.RefreshUserToGroupsMappingsResponse; |
| 41 | +import org.apache.hadoop.yarn.server.api.protocolrecords.RefreshAdminAclsRequest; |
| 42 | +import org.apache.hadoop.yarn.server.api.protocolrecords.RefreshAdminAclsResponse; |
| 43 | +import org.apache.hadoop.yarn.server.api.protocolrecords.RefreshServiceAclsRequest; |
| 44 | +import org.apache.hadoop.yarn.server.api.protocolrecords.RefreshServiceAclsResponse; |
| 45 | +import org.apache.hadoop.yarn.server.api.protocolrecords.UpdateNodeResourceRequest; |
| 46 | +import org.apache.hadoop.yarn.server.api.protocolrecords.UpdateNodeResourceResponse; |
| 47 | +import org.apache.hadoop.yarn.server.api.protocolrecords.RefreshNodesResourcesRequest; |
| 48 | +import org.apache.hadoop.yarn.server.api.protocolrecords.RefreshNodesResourcesResponse; |
| 49 | +import org.apache.hadoop.yarn.server.api.protocolrecords.AddToClusterNodeLabelsRequest; |
| 50 | +import org.apache.hadoop.yarn.server.api.protocolrecords.AddToClusterNodeLabelsResponse; |
| 51 | +import org.apache.hadoop.yarn.server.api.protocolrecords.RemoveFromClusterNodeLabelsRequest; |
| 52 | +import org.apache.hadoop.yarn.server.api.protocolrecords.RemoveFromClusterNodeLabelsResponse; |
| 53 | +import org.apache.hadoop.yarn.server.api.protocolrecords.ReplaceLabelsOnNodeRequest; |
| 54 | +import org.apache.hadoop.yarn.server.api.protocolrecords.ReplaceLabelsOnNodeResponse; |
| 55 | +import org.apache.hadoop.yarn.server.api.protocolrecords.CheckForDecommissioningNodesRequest; |
| 56 | +import org.apache.hadoop.yarn.server.api.protocolrecords.CheckForDecommissioningNodesResponse; |
| 57 | +import org.apache.hadoop.yarn.server.api.protocolrecords.NodesToAttributesMappingRequest; |
| 58 | +import org.apache.hadoop.yarn.server.api.protocolrecords.AttributeMappingOperationType; |
| 59 | +import org.apache.hadoop.yarn.server.api.protocolrecords.NodeToAttributes; |
| 60 | +import org.apache.hadoop.yarn.server.api.protocolrecords.FederationQueueWeight; |
| 61 | +import org.apache.hadoop.yarn.server.api.protocolrecords.SaveFederationQueuePolicyRequest; |
| 62 | +import org.apache.hadoop.yarn.server.api.protocolrecords.SaveFederationQueuePolicyResponse; |
| 63 | +import org.apache.hadoop.yarn.server.api.protocolrecords.BatchSaveFederationQueuePoliciesRequest; |
| 64 | +import org.apache.hadoop.yarn.server.api.protocolrecords.BatchSaveFederationQueuePoliciesResponse; |
35 | 65 | import org.apache.hadoop.yarn.server.federation.policies.dao.WeightedPolicyInfo; |
36 | 66 | import org.apache.hadoop.yarn.server.federation.policies.manager.WeightedLocalityPolicyManager; |
37 | 67 | import org.apache.hadoop.yarn.server.federation.store.impl.MemoryFederationStateStore; |
|
48 | 78 | import java.io.IOException; |
49 | 79 | import java.nio.ByteBuffer; |
50 | 80 | import java.text.DecimalFormat; |
51 | | -import java.util.*; |
| 81 | +import java.util.ArrayList; |
| 82 | +import java.util.Collections; |
| 83 | +import java.util.HashMap; |
| 84 | +import java.util.List; |
| 85 | +import java.util.Map; |
| 86 | +import java.util.Set; |
| 87 | +import java.util.HashSet; |
| 88 | +import java.util.Random; |
52 | 89 |
|
53 | 90 | import static org.junit.Assert.assertEquals; |
54 | 91 | import static org.junit.Assert.assertNotNull; |
|
0 commit comments