AMBARI-21587 Don't set restart indicators for NN/RM during DN/NM deletion (unit test fix) (dsen)
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/9f6a5a66 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/9f6a5a66 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/9f6a5a66 Branch: refs/heads/branch-2.6 Commit: 9f6a5a66ac59a1468383957acd37010eabfa8908 Parents: 9d80540 Author: Dmytro Sen <[email protected]> Authored: Fri Jul 28 12:15:30 2017 +0300 Committer: Dmytro Sen <[email protected]> Committed: Fri Jul 28 12:15:30 2017 +0300 ---------------------------------------------------------------------- .../server/controller/AmbariManagementControllerTest.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/9f6a5a66/ambari-server/src/test/java/org/apache/ambari/server/controller/AmbariManagementControllerTest.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/test/java/org/apache/ambari/server/controller/AmbariManagementControllerTest.java b/ambari-server/src/test/java/org/apache/ambari/server/controller/AmbariManagementControllerTest.java index 8afa0ef..2b8bf93 100644 --- a/ambari-server/src/test/java/org/apache/ambari/server/controller/AmbariManagementControllerTest.java +++ b/ambari-server/src/test/java/org/apache/ambari/server/controller/AmbariManagementControllerTest.java @@ -10225,7 +10225,11 @@ public class AmbariManagementControllerTest { List<Long> requestIDs = actionDB.getRequestsByStatus(null, 1, false); Request request = actionDB.getRequest(requestIDs.get(0)); assertEquals("Update Include and Exclude Files for [HDFS]", request.getRequestContext()); - assertEquals("{\"multi_services_decom_request\":\"true\",\"update_files_only\":\"false\"}", request.getInputs()); + Type type = new TypeToken<Map<String, String>>(){}.getType(); + Map<String, String> requestParams = StageUtils.getGson().fromJson(request.getInputs(), type); + assertEquals(2, requestParams.size()); + assertEquals("true", requestParams.get("multi_services_decom_request")); + assertEquals("false", requestParams.get("update_files_only")); assertEquals(1, request.getResourceFilters().size()); RequestResourceFilter resourceFilter = request.getResourceFilters().get(0); assertEquals(resourceFilter.getServiceName(), hdfsService);
