YARN-7614. [RESERVATION] Support ListReservation APIs in Federation Router.#4843
YARN-7614. [RESERVATION] Support ListReservation APIs in Federation Router.#4843goiri merged 17 commits intoapache:trunkfrom
Conversation
|
💔 -1 overall
This message was automatically generated. |
|
💔 -1 overall
This message was automatically generated. |
|
🎊 +1 overall
This message was automatically generated. |
|
💔 -1 overall
This message was automatically generated. |
|
🎊 +1 overall
This message was automatically generated. |
| long deadline = (long) (arrival + 1.05 * duration); | ||
| ReservationSubmissionRequest submissionRequest = | ||
| ReservationSystemTestUtil.createSimpleReservationRequest(reservationID, 4, | ||
| arrival, deadline, duration); |
| // Generate reserved resources | ||
| ClientRMService clientService = mockRM.getClientRMService(); | ||
| long arrival = Time.now(); | ||
| long duration = 60000; |
There was a problem hiding this comment.
We probably want to have reasons for these constants even though is just a mock.
| */ | ||
| private SubClusterInfo getHomeSubClusterInfoByReservationId(String resId) | ||
| throws YarnException { | ||
| SubClusterInfo subClusterInfo = null; |
There was a problem hiding this comment.
Declare it where we use it or even just return.
|
💔 -1 overall
This message was automatically generated. |
|
💔 -1 overall
This message was automatically generated. |
|
🎊 +1 overall
This message was automatically generated. |
|
💔 -1 overall
This message was automatically generated. |
|
💔 -1 overall
This message was automatically generated. |
|
🎊 +1 overall
This message was automatically generated. |
|
@goiri Please help to review the code again, thank you very much! |
| String applyReservationId = reservationId.toString(); | ||
| Response listReservationResponse = | ||
| interceptor.listReservation(MockDefaultRequestInterceptorREST.QUEUE_DEDICATED_FULL, | ||
| applyReservationId, -1, -1, false, null); |
|
💔 -1 overall
This message was automatically generated. |
|
hadoop.yarn.server.router.webapp.TestRouterWebServicesREST doesn't look healthy. |
I will look into the cause as soon as possible and fix it. I checked the test report and found no key information. I added the exception log to print. If there is a problem, it can be easily located. |
|
🎊 +1 overall
This message was automatically generated. |
|
@goiri Can you help merge this pr into trunk branch? I am continuing to finish YARN-11226 on the basis of this pr. Thank you very much!
From a personal point of view, the change of this pr should not affect the operation of TestRouterWebServicesREST. |
| } | ||
| }, 1000, 10 * 1000); | ||
| } catch (Exception e) { | ||
| LOG.error("Web app not running", e); |
There was a problem hiding this comment.
Why do we do this? Isn't it clear enough with the "fail()" message?
There was a problem hiding this comment.
Why do we do this? Isn't it clear enough with the "fail()" message?
I understand your thoughts, you are right, the "fail()" message is enough, generally it is caused by timeout, I increased the timeout.
|
💔 -1 overall
This message was automatically generated. |
|
🎊 +1 overall
This message was automatically generated. |
|
🎊 +1 overall
This message was automatically generated. |
|
@goiri Thank you very much for helping to review the code! |
JIRA: YARN-7614. [RESERVATION] Support ListReservation APIs in Federation Router.