org.apache.ambari.server.upgrade

Class UpgradeCatalog271

java.lang.Object

org.apache.ambari.server.upgrade.AbstractUpgradeCatalog

org.apache.ambari.server.upgrade.UpgradeCatalog271

All Implemented Interfaces:

UpgradeCatalog

public class UpgradeCatalog271
extends AbstractUpgradeCatalog

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ambari.server.upgrade.AbstractUpgradeCatalog

AbstractUpgradeCatalog.ConfigUpdateType, AbstractUpgradeCatalog.VersionComparator

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	CLUSTERS_BLUEPRINT_PROVISIONING_STATE_COLUMN
protected static String	CLUSTERS_TABLE

Fields inherited from class org.apache.ambari.server.upgrade.AbstractUpgradeCatalog

ALERT_URL_PROPERTY_CONNECTION_TIMEOUT, ambariManagementController, ambariSequencesTable, ambariUpgradeConfigUpdatesFileName, AUTHENTICATED_USER_NAME, configuration, CONFIGURATION_TYPE_RANGER_HBASE_PLUGIN_PROPERTIES, CONFIGURATION_TYPE_RANGER_HIVE_PLUGIN_PROPERTIES, CONFIGURATION_TYPE_RANGER_KNOX_PLUGIN_PROPERTIES, dbAccessor, injector, PROPERTY_RANGER_HBASE_PLUGIN_ENABLED, PROPERTY_RANGER_HIVE_PLUGIN_ENABLED, PROPERTY_RANGER_KNOX_PLUGIN_ENABLED, QUEUES, YARN_SCHEDULER_CAPACITY_ROOT_QUEUE, YARN_SCHEDULER_CAPACITY_ROOT_QUEUES

Constructor Summary

Constructors

Constructor and Description
UpgradeCatalog271(com.google.inject.Injector injector) Constructor

Method Summary

Modifier and Type	Method and Description
protected void	addBlueprintProvisioningState()
protected void	executeDDLUpdates() Perform database schema transformation.
protected void	executeDMLUpdates() Performs normal data upgrade
protected void	executePreDMLUpdates() Perform data insertion before running normal upgrade of data, requires started persist service
String	getSourceVersion() Return latest source version that can be upgraded from.
String	getTargetVersion() Return the version that will be upgraded to
protected void	removeLogSearchPatternConfigs() Removes config types with -logsearch-conf suffix
protected void	renameAmbariInfraService()
protected void	updateRangerKmsDbUrl() Updating JDBC connection url in Ranger KMS for verifying communication to database using database root user credentials
protected void	updateRangerLogDirConfigs() Updating Ranger Admin and Ranger Usersync log directory configs
protected void	updateSolrConfigurations() Upgrade lucene version to 7.4.0 in Solr config of Log Search collections and Solr Log4j config
protected void	updateTimelineReaderAddress() Replace placeholder values in timeline reader address.

Methods inherited from class org.apache.ambari.server.upgrade.AbstractUpgradeCatalog

addAuthorizationToRole, addAuthorizationToRole, addAuthorizationToRole, addConnectionTimeoutParamForWebAndMetricAlerts, addNewConfigurationsFromXml, addRoleAuthorization, addSequence, addSequences, changePostgresSearchPath, convertStringToDocument, executeInTransaction, fetchMaxId, getCapacitySchedulerLeafQueues, getCheckedClusterMap, getEntityManagerProvider, getKerberosDescriptor, getUpgradeCatalog, getUpgradeJsonOutput, isConfigEnabled, isFinal, isNNHAEnabled, isQueueNameValid, onPostUpgrade, preUpgradeData, registerCatalog, removeConfigurationPropertiesFromCluster, setConfigUpdatesFileName, toString, updateConfigurationProperties, updateConfigurationPropertiesForCluster, updateConfigurationPropertiesForCluster, updateConfigurationPropertiesWithValuesFromXml, updateConfigurationPropertiesWithValuesFromXml, updateDatabaseSchemaVersion, updateKerberosDescriptorArtifact, updateKerberosDescriptorArtifacts, updateKerberosDescriptorIdentityReferences, updateKerberosDescriptorIdentityReferences, updateMetaInfoVersion, updateQueueName, updateWidgetDefinitionsForService, upgradeData, upgradeSchema

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

CLUSTERS_TABLE

protected static final String CLUSTERS_TABLE

See Also:

Constant Field Values

CLUSTERS_BLUEPRINT_PROVISIONING_STATE_COLUMN

protected static final String CLUSTERS_BLUEPRINT_PROVISIONING_STATE_COLUMN

See Also:

Constant Field Values

Constructor Detail

UpgradeCatalog271

@Inject
public UpgradeCatalog271(com.google.inject.Injector injector)

Constructor

Parameters:

injector -

Method Detail

getTargetVersion

public String getTargetVersion()

Return the version that will be upgraded to

Returns:

getSourceVersion

public String getSourceVersion()

Return latest source version that can be upgraded from. Return null since no UpgradeCatalogs exist before this one.

Specified by:

getSourceVersion in interface UpgradeCatalog

Overrides:

getSourceVersion in class AbstractUpgradeCatalog

Returns:

null : default

executeDDLUpdates

protected void executeDDLUpdates()
                          throws org.apache.ambari.server.AmbariException,
                                 SQLException

Perform database schema transformation. Can work only before persist service start

Specified by:

executeDDLUpdates in class AbstractUpgradeCatalog

Throws:

org.apache.ambari.server.AmbariException

SQLException

executePreDMLUpdates

protected void executePreDMLUpdates()
                             throws org.apache.ambari.server.AmbariException,
                                    SQLException

Perform data insertion before running normal upgrade of data, requires started persist service

Specified by:

executePreDMLUpdates in class AbstractUpgradeCatalog

Throws:

org.apache.ambari.server.AmbariException

SQLException

executeDMLUpdates

protected void executeDMLUpdates()
                          throws org.apache.ambari.server.AmbariException,
                                 SQLException

Performs normal data upgrade

Specified by:

executeDMLUpdates in class AbstractUpgradeCatalog

Throws:

org.apache.ambari.server.AmbariException

SQLException

updateRangerLogDirConfigs

protected void updateRangerLogDirConfigs()
                                  throws org.apache.ambari.server.AmbariException

Updating Ranger Admin and Ranger Usersync log directory configs

Throws:

org.apache.ambari.server.AmbariException

updateRangerKmsDbUrl

protected void updateRangerKmsDbUrl()
                             throws org.apache.ambari.server.AmbariException

Updating JDBC connection url in Ranger KMS for verifying communication to database using database root user credentials

Throws:

org.apache.ambari.server.AmbariException

updateTimelineReaderAddress

protected void updateTimelineReaderAddress()
                                    throws org.apache.ambari.server.AmbariException

Replace placeholder values in timeline reader address. In Ambari 2.7 these properties are set to {{timeline_reader_address_http}} and {{timeline_reader_address_https}} and the stack code substitutes the proper host names. In Ambari 2.7.1 the stack code no longer does this but the stack advisor and a SingleHostTopologyUpdater is responsible for replacing the hosts.

Throws:

org.apache.ambari.server.AmbariException

renameAmbariInfraService

protected void renameAmbariInfraService()

removeLogSearchPatternConfigs

protected void removeLogSearchPatternConfigs()
                                      throws SQLException

Removes config types with -logsearch-conf suffix

Throws:

SQLException

addBlueprintProvisioningState

protected void addBlueprintProvisioningState()
                                      throws SQLException

Throws:

SQLException

updateSolrConfigurations

protected void updateSolrConfigurations()
                                 throws org.apache.ambari.server.AmbariException

Upgrade lucene version to 7.4.0 in Solr config of Log Search collections and Solr Log4j config

Throws:

org.apache.ambari.server.AmbariException