protected void removeDfsHAInitial() {
    BlueprintDAO blueprintDAO = injector.getInstance(BlueprintDAO.class);
    List<BlueprintEntity> blueprintEntityList = blueprintDAO.findAll();
    List<BlueprintEntity> changedBlueprints = new ArrayList<>();
    for (BlueprintEntity blueprintEntity : blueprintEntityList){
      boolean changed = false;
      Collection<BlueprintConfigEntity> blueprintConfigurations = blueprintEntity.getConfigurations();
      for (BlueprintConfigEntity blueprintConfigEntity : blueprintConfigurations) {
        if (blueprintConfigEntity.getType().equals("hadoop-env")) {
          String configData = blueprintConfigEntity.getConfigData();

          Map<String, String> typeProperties = GSON.<Map<String, String>>fromJson(
            configData, Map.class);

          typeProperties.remove("dfs_ha_initial_namenode_standby");
          typeProperties.remove("dfs_ha_initial_namenode_active");

          blueprintConfigEntity.setConfigData(GSON.toJson(typeProperties));
          changed = true;
        }
      }
      if (changed) {
        changedBlueprints.add(blueprintEntity);
      }
    }
    for (BlueprintEntity blueprintEntity : changedBlueprints) {
      blueprintDAO.merge(blueprintEntity);
    }
  }
Performs normal data upgrade

@throws AmbariException
@throws SQLException
ambari-server/src/main/java/org/apache/ambari/server/upgrade/UpgradeCatalog275.java