Repository: ambari Updated Branches: refs/heads/branch-1.7.0 e7e5955bc -> b1821e28b
AMBARI-7867. mapreduce2-log4j is empty after upgrade to 1.7.0.(vbrodetskyi) Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/b1821e28 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/b1821e28 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/b1821e28 Branch: refs/heads/branch-1.7.0 Commit: b1821e28b413ceef07ea398bfb9931ceb4e8cc16 Parents: e7e5955 Author: Vitaly Brodetskyi <[email protected]> Authored: Mon Oct 20 17:16:26 2014 +0300 Committer: Vitaly Brodetskyi <[email protected]> Committed: Mon Oct 20 17:16:26 2014 +0300 ---------------------------------------------------------------------- .../server/configuration/Configuration.java | 1 + .../server/upgrade/UpgradeCatalog170.java | 22 ++++++++++++++++++++ .../server/upgrade/UpgradeCatalog170Test.java | 2 +- 3 files changed, 24 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/b1821e28/ambari-server/src/main/java/org/apache/ambari/server/configuration/Configuration.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/java/org/apache/ambari/server/configuration/Configuration.java b/ambari-server/src/main/java/org/apache/ambari/server/configuration/Configuration.java index 315e1a6..64eb105 100644 --- a/ambari-server/src/main/java/org/apache/ambari/server/configuration/Configuration.java +++ b/ambari-server/src/main/java/org/apache/ambari/server/configuration/Configuration.java @@ -200,6 +200,7 @@ public class Configuration { public static final String CLIENT_API_SSL_KEY_NAME_DEFAULT = "https.key"; public static final String CLIENT_API_SSL_CRT_NAME_DEFAULT = "https.crt"; public static final String GLOBAL_CONFIG_TAG = "global"; + public static final String MAPREDUCE2_LOG4J_CONFIG_TAG = "mapreduce2-log4j"; public static final String RCA_ENABLED_PROPERTY = "rca_enabled"; public static final String HIVE_CONFIG_TAG = "hive-site"; public static final String HIVE_METASTORE_PASSWORD_PROPERTY = http://git-wip-us.apache.org/repos/asf/ambari/blob/b1821e28/ambari-server/src/main/java/org/apache/ambari/server/upgrade/UpgradeCatalog170.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/java/org/apache/ambari/server/upgrade/UpgradeCatalog170.java b/ambari-server/src/main/java/org/apache/ambari/server/upgrade/UpgradeCatalog170.java index c7a2e4d..34caa48 100644 --- a/ambari-server/src/main/java/org/apache/ambari/server/upgrade/UpgradeCatalog170.java +++ b/ambari-server/src/main/java/org/apache/ambari/server/upgrade/UpgradeCatalog170.java @@ -648,6 +648,28 @@ public class UpgradeCatalog170 extends AbstractUpgradeCatalog { moveConfigGroupsGlobalToEnv(); addMissingConfigs(); updateClusterProvisionState(); + removeMapred2Log4jConfig(); + } + + private void removeMapred2Log4jConfig() { + ConfigHelper configHelper = injector.getInstance(ConfigHelper.class); + + AmbariManagementController ambariManagementController = injector.getInstance( + AmbariManagementController.class); + Clusters clusters = ambariManagementController.getClusters(); + if (clusters == null) { + return; + } + Map<String, Cluster> clusterMap = clusters.getClusters(); + + if (clusterMap != null && !clusterMap.isEmpty()) { + for (final Cluster cluster : clusterMap.values()) { + Config config = cluster.getDesiredConfigByType(Configuration.MAPREDUCE2_LOG4J_CONFIG_TAG); + if (config != null) { + configHelper.removeConfigsByType(cluster, Configuration.MAPREDUCE2_LOG4J_CONFIG_TAG); + } + } + } } public void updateClusterProvisionState() { http://git-wip-us.apache.org/repos/asf/ambari/blob/b1821e28/ambari-server/src/test/java/org/apache/ambari/server/upgrade/UpgradeCatalog170Test.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/test/java/org/apache/ambari/server/upgrade/UpgradeCatalog170Test.java b/ambari-server/src/test/java/org/apache/ambari/server/upgrade/UpgradeCatalog170Test.java index 3271864..a02a962 100644 --- a/ambari-server/src/test/java/org/apache/ambari/server/upgrade/UpgradeCatalog170Test.java +++ b/ambari-server/src/test/java/org/apache/ambari/server/upgrade/UpgradeCatalog170Test.java @@ -502,7 +502,7 @@ public class UpgradeCatalog170Test { expect(amc.getClusters()).andReturn(clusters).anyTimes(); expect(clusters.getClusters()).andReturn(clustersMap).anyTimes(); expect(clusters.getClusterById(1L)).andReturn(clustersMap.values().iterator().next()).anyTimes(); - expect(clusters.getClusters()).andReturn(clustersMap).once(); + expect(clusters.getClusters()).andReturn(clustersMap).times(2); expect(cluster.getDesiredConfigByType("global")).andReturn(config).anyTimes(); expect(cluster.getDesiredConfigByType("oozie-log4j")).andReturn(config).anyTimes(); expect(cluster.getClusterId()).andReturn(1L);
