|
44 | 44 | import org.apache.hadoop.security.authorize.AuthorizationException;
|
45 | 45 | import org.apache.hadoop.util.Sets;
|
46 | 46 | import org.apache.hadoop.util.Time;
|
47 |
| -import org.apache.hadoop.yarn.api.protocolrecords.*; |
| 47 | +import org.apache.hadoop.yarn.api.protocolrecords.ReservationDeleteRequest; |
| 48 | +import org.apache.hadoop.yarn.api.protocolrecords.ReservationListRequest; |
| 49 | +import org.apache.hadoop.yarn.api.protocolrecords.ReservationListResponse; |
| 50 | +import org.apache.hadoop.yarn.api.protocolrecords.ReservationSubmissionRequest; |
| 51 | +import org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateRequest; |
48 | 52 | import org.apache.hadoop.yarn.api.records.ApplicationId;
|
49 | 53 | import org.apache.hadoop.yarn.api.records.ReservationId;
|
50 | 54 | import org.apache.hadoop.yarn.api.records.Resource;
|
|
74 | 78 | import org.apache.hadoop.yarn.server.resourcemanager.MockRM;
|
75 | 79 | import org.apache.hadoop.yarn.server.resourcemanager.RMContext;
|
76 | 80 | import org.apache.hadoop.yarn.server.resourcemanager.reservation.ReservationSystem;
|
| 81 | +import org.apache.hadoop.yarn.server.resourcemanager.reservation.ReservationSystemTestUtil; |
77 | 82 | import org.apache.hadoop.yarn.server.resourcemanager.rmapp.RMApp;
|
78 | 83 | import org.apache.hadoop.yarn.server.resourcemanager.scheduler.ActiveUsersManager;
|
79 | 84 | import org.apache.hadoop.yarn.server.resourcemanager.scheduler.ResourceScheduler;
|
|
88 | 93 | import org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica.FiCaSchedulerApp;
|
89 | 94 | import org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica.FiCaSchedulerNode;
|
90 | 95 | import org.apache.hadoop.yarn.server.resourcemanager.webapp.NodeIDsInfo;
|
91 |
| -import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.*; |
| 96 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NodeLabelsInfo; |
| 97 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.LabelsToNodesInfo; |
| 98 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppInfo; |
| 99 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppState; |
| 100 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ApplicationSubmissionContextInfo; |
| 101 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppsInfo; |
| 102 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ClusterMetricsInfo; |
| 103 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NewApplication; |
| 104 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NodeInfo; |
| 105 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NodesInfo; |
| 106 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ResourceInfo; |
| 107 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ResourceOptionInfo; |
| 108 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NodeToLabelsInfo; |
| 109 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NodeLabelInfo; |
| 110 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppAttemptsInfo; |
| 111 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppTimeoutInfo; |
| 112 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppTimeoutsInfo; |
| 113 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppPriority; |
| 114 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppQueue; |
| 115 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.StatisticsItemInfo; |
| 116 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ApplicationStatisticsInfo; |
| 117 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppActivitiesInfo; |
| 118 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NewReservation; |
| 119 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ReservationSubmissionRequestInfo; |
| 120 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ReservationUpdateRequestInfo; |
| 121 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ReservationDeleteRequestInfo; |
| 122 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ReservationListInfo; |
| 123 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ReservationDefinitionInfo; |
| 124 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ReservationRequestInfo; |
| 125 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ReservationRequestsInfo; |
| 126 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ReservationUpdateResponseInfo; |
| 127 | +import org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ReservationDeleteResponseInfo; |
92 | 128 | import org.apache.hadoop.yarn.server.router.RouterServerUtil;
|
93 | 129 | import org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey;
|
94 | 130 | import org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo;
|
|
0 commit comments