Repository: ambari Updated Branches: refs/heads/trunk 4759196f3 -> 0a14f07c8
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/0a14f07c Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/0a14f07c Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/0a14f07c Branch: refs/heads/trunk Commit: 0a14f07c842e8afd0c51359e1bfd9c8fe18d607f Parents: 4759196 Author: Dmytro Sen <[email protected]> Authored: Fri Jul 28 12:13:13 2017 +0300 Committer: Dmytro Sen <[email protected]> Committed: Fri Jul 28 12:13:13 2017 +0300 ---------------------------------------------------------------------- .../server/controller/AmbariManagementControllerTest.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/0a14f07c/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 cf78130..7a09d7b 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 @@ -9388,7 +9388,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);
