You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by jo...@apache.org on 2017/07/31 14:01:32 UTC

[08/16] ambari git commit: AMBARI-21587 Don't set restart indicators for NN/RM during DN/NM deletion (unit test fix) (dsen)

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 <ds...@apache.org>
Authored: Fri Jul 28 12:15:30 2017 +0300
Committer: Dmytro Sen <ds...@apache.org>
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);