public class UpgradeCatalog260 extends AbstractUpgradeCatalog
UpgradeCatalog260
upgrades Ambari from 2.5.2 to 2.6.0.AbstractUpgradeCatalog.ConfigUpdateType, AbstractUpgradeCatalog.VersionComparator
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 and Description |
---|
UpgradeCatalog260(com.google.inject.Injector injector)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
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
|
protected void |
fixRangerKMSKerberosDescriptor(KerberosDescriptor kerberosDescriptor) |
protected void |
fixYarnHsiKerberosDescriptorAndSiteConfig(Cluster cluster,
KerberosDescriptor kerberosDescriptor)
Updates YARN's NM 'llap_zk_hive' kerberos descriptor as reference and the associated config
hive-interactive-site/hive.llap.zk.sm.keytab.file
|
Integer |
getCurrentVersionID()
|
String |
getSourceVersion()
Return latest source version that can be upgraded from.
|
String |
getTargetVersion()
Return the version that will be upgraded to
|
List<String> |
getYarnKerberosDescUpdatedList() |
protected void |
removeSupersetFromDruid() |
protected void |
updateAmsConfigs() |
protected void |
updateExistingRepositoriesToBeResolved()
Sets all existing repository versions to be resolved (we have to assume
that they are good since they've been using them to run stuff).
|
protected void |
updateHDFSWidgetDefinition() |
protected void |
updateHiveConfigs() |
protected void |
updateKerberosDescriptorArtifact(ArtifactDAO artifactDAO,
ArtifactEntity artifactEntity)
Update the specified Kerberos Descriptor artifact to conform to the new structure.
|
void |
updateYarnKerberosDescUpdatedList(String val) |
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, updateKerberosDescriptorArtifacts, updateKerberosDescriptorIdentityReferences, updateKerberosDescriptorIdentityReferences, updateMetaInfoVersion, updateQueueName, updateWidgetDefinitionsForService, upgradeData, upgradeSchema
public static final String CLUSTER_CONFIG_MAPPING_TABLE
public static final String CLUSTER_VERSION_TABLE
public static final String CLUSTER_ID_COLUMN
public static final String STATE_COLUMN
public static final String CREATE_TIMESTAMP_COLUMN
public static final String VERSION_TAG_COLUMN
public static final String TYPE_NAME_COLUMN
public static final String CLUSTER_CONFIG_TABLE
public static final String SELECTED_COLUMN
public static final String SERVICE_DELETED_COLUMN
public static final String UNMAPPED_COLUMN
public static final String SELECTED_TIMESTAMP_COLUMN
public static final String SERVICE_COMPONENT_DESIRED_STATE_TABLE
public static final String DESIRED_STACK_ID_COLUMN
public static final String DESIRED_VERSION_COLUMN
public static final String DESIRED_REPO_VERSION_ID_COLUMN
public static final String REPO_STATE_COLUMN
public static final String FK_SCDS_DESIRED_STACK_ID
public static final String FK_SERVICECOMPONENTDESIREDSTATE_DESIRED_STACK_ID
public static final String FK_SCDS_DESIRED_REPO_ID
public static final String REPO_VERSION_TABLE
public static final String REPO_VERSION_ID_COLUMN
public static final String REPO_VERSION_RESOLVED_COLUMN
public static final String REPO_VERSION_HIDDEN_COLUMN
public static final String REPO_VERSION_LEGACY_COLUMN
public static final String HOST_COMPONENT_DESIRED_STATE_TABLE
public static final String FK_HCDS_DESIRED_STACK_ID
public static final String HOST_COMPONENT_STATE_TABLE
public static final String CURRENT_STACK_ID_COLUMN
public static final String FK_HCS_CURRENT_STACK_ID
public static final String HOST_VERSION_TABLE
public static final String UQ_HOST_REPO
public static final String HOST_ID_COLUMN
public static final String SERVICE_DESIRED_STATE_TABLE
public static final String FK_SDS_DESIRED_STACK_ID
public static final String FK_REPO_VERSION_ID
public static final String CLUSTERS_TABLE
public static final String UPGRADE_TABLE
public static final String UPGRADE_GROUP_TABLE
public static final String UPGRADE_ITEM_TABLE
public static final String FROM_REPO_VERSION_ID_COLUMN
public static final String TO_REPO_VERSION_ID_COLUMN
public static final String ORCHESTRATION_COLUMN
public static final String ALLOW_REVERT_COLUMN
public static final String FK_UPGRADE_FROM_REPO_ID
public static final String FK_UPGRADE_TO_REPO_ID
public static final String FK_UPGRADE_REPO_VERSION_ID
public static final String UPGRADE_ITEM_ITEM_TEXT
public static final String SERVICE_COMPONENT_HISTORY_TABLE
public static final String UPGRADE_HISTORY_TABLE
public static final String ID_COLUMN
public static final String UPGRADE_ID_COLUMN
public static final String SERVICE_NAME_COLUMN
public static final String COMPONENT_NAME_COLUMN
public static final String TARGET_REPO_VERSION_ID_COLUMN
public static final String PK_UPGRADE_HIST
public static final String FK_UPGRADE_HIST_UPGRADE_ID
public static final String FK_UPGRADE_HIST_FROM_REPO
public static final String FK_UPGRADE_HIST_TARGET_REPO
public static final String UQ_UPGRADE_HIST
public static final String SERVICE_CONFIG_MAPPING_TABLE
public static final String SERVICE_COMPONENT_DESIRED_STATE
public static final String HOST_COMPONENT_DESIRED_STATE
public static final String HOST_COMPONENT_STATE
public static final String AMS_SSL_CLIENT
public static final String METRIC_TRUSTSTORE_ALIAS
public static final String HIVE_LLAP_DAEMON_KEYTAB_FILE
public static final String HIVE_LLAP_ZK_SM_KEYTAB_FILE
public static final String HIVE_LLAP_TASK_KEYTAB_FILE
public static final String HIVE_SERVER_KERBEROS_PREFIX
public static final String YARN_LLAP_ZK_HIVE_KERBEROS_IDENTITY
public static final String YARN_LLAP_TASK_HIVE_KERBEROS_IDENTITY
public static final String HIVE_SERVER_HIVE_KERBEROS_IDENTITY
public static final String STANDARD
public static final String NOT_REQUIRED
public static final String CURRENT
public static final String SELECTED
public static final String VIEWURL_TABLE
public static final String VIEWINSTANCE_TABLE
public static final String PK_VIEWURL
public static final String URL_ID_COLUMN
public static final String STALE_POSTGRESS_VIEWURL_PKEY
public static final String USERS_TABLE
public static final String STALE_POSTGRESS_USERS_LDAP_USER_KEY
public static final String SHORT_URL_COLUMN
public static final String FK_INSTANCE_URL_ID
public static final String FK_SERVICEDESIREDSTATE_DESIRED_STACK_ID
public static final String FK_HOSTCOMPONENTDESIREDSTATE_DESIRED_STACK_ID
public static final String FK_HOSTCOMPONENTSTATE_CURRENT_STACK_ID
public static final String FK_UPGRADE_FROM_REPO_VERSION_ID
public static final String FK_UPGRADE_TO_REPO_VERSION_ID
@Inject public UpgradeCatalog260(com.google.inject.Injector injector)
injector
- public String getSourceVersion()
getSourceVersion
in interface UpgradeCatalog
getSourceVersion
in class AbstractUpgradeCatalog
public String getTargetVersion()
protected void executeDDLUpdates() throws org.apache.ambari.server.AmbariException, SQLException
executeDDLUpdates
in class AbstractUpgradeCatalog
org.apache.ambari.server.AmbariException
SQLException
protected void executePreDMLUpdates() throws org.apache.ambari.server.AmbariException, SQLException
executePreDMLUpdates
in class AbstractUpgradeCatalog
org.apache.ambari.server.AmbariException
SQLException
protected void executeDMLUpdates() throws org.apache.ambari.server.AmbariException, SQLException
executeDMLUpdates
in class AbstractUpgradeCatalog
org.apache.ambari.server.AmbariException
SQLException
public Integer getCurrentVersionID() throws org.apache.ambari.server.AmbariException, SQLException
org.apache.ambari.server.AmbariException
- if cluster versions are present, but current is not selectedSQLException
protected void removeSupersetFromDruid() throws SQLException
SQLException
protected void updateKerberosDescriptorArtifact(ArtifactDAO artifactDAO, ArtifactEntity artifactEntity) throws org.apache.ambari.server.AmbariException
updateKerberosDescriptorArtifact
in class AbstractUpgradeCatalog
artifactDAO
- the ArtifactDAO to use to store the updated ArtifactEntityartifactEntity
- the ArtifactEntity to updateorg.apache.ambari.server.AmbariException
protected void fixRangerKMSKerberosDescriptor(KerberosDescriptor kerberosDescriptor)
protected void fixYarnHsiKerberosDescriptorAndSiteConfig(Cluster cluster, KerberosDescriptor kerberosDescriptor)
public void updateYarnKerberosDescUpdatedList(String val)
protected void updateHiveConfigs() throws org.apache.ambari.server.AmbariException
org.apache.ambari.server.AmbariException
protected void updateAmsConfigs() throws org.apache.ambari.server.AmbariException
org.apache.ambari.server.AmbariException
protected void updateHDFSWidgetDefinition() throws org.apache.ambari.server.AmbariException
org.apache.ambari.server.AmbariException
protected void updateExistingRepositoriesToBeResolved() throws org.apache.ambari.server.AmbariException
org.apache.ambari.server.AmbariException
Copyright © 2022 Apache Software Foundation. All rights reserved.