Post Syndicated from Jianwei Li original https://aws.amazon.com/blogs/big-data/upgrade-amazon-emr-hive-metastore-from-5-x-to-6-x/

If you are currently running Amazon EMR 5.X clusters, consider moving to Amazon EMR 6.X as  it includes new features that helps you improve performance and optimize on cost. For instance, Apache Hive is two times faster with LLAP on Amazon EMR 6.X, and Spark 3 reduces costs by 40%. Additionally, Amazon EMR 6.x releases include Trino, a fast distributed SQL engine and Iceberg, high-performance open data format for petabyte scale tables.

To upgrade Amazon EMR clusters from 5.X to 6.X release, a Hive Metastore upgrade is the first step before applications such as Hive and Spark can be migrated. This post provides guidance on how to upgrade Amazon EMR Hive Metastore from 5.X to 6.X as well as migration of Hive Metastore to the AWS Glue Data Catalog. As Hive 3 Metastore is compatible with Hive 2 applications, you can continue to use Amazon EMR 5.X with the upgraded Hive Metastore.

Solution overview

In the following section, we provide steps to upgrade the Hive Metastore schema using MySQL as the backend.. For any other backends (such as MariaDB, Oracle, or SQL Server), update the commands accordingly.

There are two options to upgrade the Amazon EMR Hive Metastore:

• Upgrade the Hive Metastore schema from 2.X to 3.X by using the Hive Schema Tool
• Migrate the Hive Metastore to the AWS Glue Data Catalog

We walk through the steps for both options.

Pre-upgrade prerequisites

Before upgrading the Hive Metastore, you must complete the following prerequisites steps:

1. Verify the Hive Metastore database is running and accessible.
   You should be able to run Hive DDL and DML queries successfully. Any errors or issues must be fixed before proceeding with upgrade process. Use the following sample queries to test the database:

   create table testtable1 (id int, name string);)
   insert into testtable1 values (1001, "user1");
   select * from testtable1;

2. To get the Metastore schema version in the current EMR 5.X cluster, run the following command in the primary node:

   sudo hive —service schematool -dbType mysql -info

   The following code shows our sample output:

   $ sudo hive --service schematool -dbType mysql -info
   Metastore connection URL: jdbc:mysql://xxxxxxx.us-east-1.rds.amazonaws.com:3306/hive?createDatabaseIfNotExist=true
   Metastore Connection Driver : org.mariadb.jdbc.Driver
   Metastore connection User: admin
   Hive distribution version: 2.3.0
   Metastore schema version:  2.3.0

3. Stop the Metastore service and restrict access to the Metastore MySQL database.
   It’s very important that no one else accesses or modifies the contents of the Metastore database while you’re performing the schema upgrade.To stop the Metastore, use the following commands:

   $ sudo stop hive-server2
   $ sudo stop hive-hcatalog-server

   For Amazon EMR release 5.30 and 6.0 onwards (Amazon Linux 2 is the operating system for the Amazon EMR 5.30+ and 6.x release series), use the following commands:

   $ sudo systemctl stop hive-server2.service
   $ sudo systemctl stop hive-hcatalog-server.service

   You can also note the total number of databases and tables present in the Hive Metastore before the upgrade, and verify the number of databases and tables after the upgrade.

4. To get the total number of tables and databases before the upgrade, run the following commands after connecting to the external Metastore database (assuming the Hive Metadata DB name is hive):

   $mysql -u <username> -h <mysqlhost> --password;
   $use hive;
   $select count(*) from DBS;
   $select count(*) from TBLS;

5. Take a backup or snapshot of the Hive database.
   This allows you to revert any changes made during the upgrade process if something goes wrong. If you’re using Amazon Relational Database Service (Amazon RDS), refer to Backing up and restoring an Amazon RDS instance for instructions.
6. Take note of the Hive table storage location if data is stored in HDFS.

If all the table data is on Amazon Simple Storage Service (Amazon S3), then no action is needed. If HDFS is used as the storage layer for Hive databases and tables, then take a note of them. You will need to copy the files on HDFS to a similar path on the new cluster, and then verify or update the location attribute for databases and tables on the new cluster accordingly.

Upgrade the Amazon EMR Hive Metastore schema with the Hive Schema Tool

In this approach, you use the persistent Hive Metastore on a remote database (Amazon RDS for MySQL or Amazon Aurora MySQL-Compatible Edition). The following diagram shows the upgrade procedure.

To upgrade the Amazon EMR Hive Metastore from 5.X (Hive version 2.X) to 6.X (Hive version 3.X), we can use the Hive Schema Tool. The Hive Schema Tool is an offline tool for Metastore schema manipulation. You can use it to initialize, upgrade, and validate the Metastore schema. Run the following command to show the available options for the Hive Schema Tool:

sudo hive --service schematool -help

Be sure to complete the prerequisites mentioned earlier, including taking a backup or snapshot, before proceeding with the next steps.

1. Note down the details of the existing Hive external Metastore to be upgraded.
   This includes the RDS for MySQL endpoint host name, database name (for this post, hive), user name, and password. You can do this through one of the following options:
   • Get the Hive Metastore DB information from the Hive configuration file – Log in to the EMR 5.X primary node, open the file /etc/hive/conf/hive-site.xml, and note the four properties:

     <property>
     	  <name>javax.jdo.option.ConnectionURL</name>
     	  <value>jdbc:mysql://{hostname}:3306/{dbname}?createDatabaseIfNotExist=true</value>
     	  <description>username to use against metastore database</description>
     	</property>
     	<property>
     	  <name>javax.jdo.option.ConnectionDriverName</name>
     	  <value>org.mariadb.jdbc.Driver</value>
     	  <description>username to use against metastore database</description>
     	</property>
     	<property>
     	  <name>javax.jdo.option.ConnectionUserName</name>
     	  <value>{username}</value>
     	  <description>username to use against metastore database</description>
     	</property>
     	<property>
     	  <name>javax.jdo.option.ConnectionPassword</name>
     	  <value>{password}</value>
     	  <description>password to use against metastore database</description>
     	</property>

   • Get the Hive Metastore DB information from the Amazon EMR console – Navigate to the EMR 5.X cluster, choose the Configurations tab, and note down the Metastore DB information.
     

2. Create a new EMR 6.X cluster.
   To use the Hive Schema Tool, we need to create an EMR 6.X cluster. You can create a new EMR 6.X cluster via the Hive console or the AWS Command Line Interface (AWS CLI), without specifying external hive Metastore details. This lets the EMR 6.X cluster launch successfully using the default Hive Metastore. For more information about EMR cluster management, refer to Plan and configure clusters.
3. After your new EMR 6.X cluster is launched successfully and is in the waiting state, SSH to the EMR 6.X primary node and take a backup of /etc/hive/conf/hive-site.xml:

   sudo cp /etc/hive/conf/hive-site.xml /etc/hive/conf/hive-site.xml.bak

4. Stop Hive services:

   sudo systemctl stop hive-hcatalog-server.service
   sudo systemctl stop hive-server2.service

   Now you update the Hive configuration and point it to the old hive Metastore database.

5. Modify /etc/hive/conf/hive-site.xml and update the properties with the values you collected earlier:

   <property>
     <name>javax.jdo.option.ConnectionURL</name>
     <value>jdbc:mysql://{hostname}:3306/{dbname}?createDatabaseIfNotExist=true</value>
     <description>username to use against metastore database</description>
   </property>
   <property>
     <name>javax.jdo.option.ConnectionDriverName</name>
     <value>org.mariadb.jdbc.Driver</value>
     <description>username to use against metastore database</description>
   </property>
   <property>
     <name>javax.jdo.option.ConnectionUserName</name>
     <value>{username}</value>
     <description>username to use against metastore database</description>
   </property>
   <property>
     <name>javax.jdo.option.ConnectionPassword</name>
     <value>{password}</value>
     <description>password to use against metastore database</description>
   </property>

6. On the same or new SSH session, run the Hive Schema Tool to check that the Metastore is pointing to the old Metastore database:

   sudo hive --service schemaTool -dbType mysql -info

   The output should look as follows (old-hostname, old-dbname, and old-username are the values you changed):

   Metastore connection URL:     jdbc:mysql://{old-hostname}:3306/{old-dbname}?createDatabaseIfNotExist=true
   Metastore Connection Driver :     org.mariadb.jdbc.Driver
   Metastore connection User:     {old-username}
   Hive distribution version:     3.1.0
   Metastore schema version:      2.3.0
   schemaTool completed

   You can upgrade the Hive Metastore by passing the -upgradeSchema option to the Hive Schema Tool. The tool figures out the SQL scripts required to initialize or upgrade the schema and then runs those scripts against the backend database.

7. Run the upgradeSchema command with -dryRun, which only lists the SQL scripts needed during the actual run:

   sudo hive --service schematool -dbType mysql -upgradeSchema -dryRun

   The output should look like the following code. It shows the Metastore upgrade path from the old version to the new version. You can find the upgrade order on the GitHub repo. In case of failure during the upgrade process, these scripts can be run manually in the same order.

   Metastore connection URL:     jdbc:mysql://{old-hostname}:3306/{old-dbname}?createDatabaseIfNotExist=true
   Metastore Connection Driver :     org.mariadb.jdbc.Driver
   Metastore connection User:     {old-username}
   Hive distribution version:     3.1.0
   Metastore schema version:      2.3.0
   schemaTool completed

8. To upgrade the Hive Metastore schema, run the Hive Schema Tool with -upgradeSchema:

   sudo hive --service schematool -dbType mysql -upgradeSchema

   The output should look like the following code:

   Starting upgrade metastore schema from version 2.3.0 to 3.1.0
   Upgrade script upgrade-2.3.0-to-3.0.0.mysql.sql
   ...
   Completed upgrade-2.3.0-to-3.0.0.mysql.sql
   Upgrade script upgrade-3.0.0-to-3.1.0.mysql.sql
   ...
   Completed upgrade-3.0.0-to-3.1.0.mysql.sql
   schemaTool completed

   In case of any issues or failures, you can run the preceding command with verbose. This prints all the queries getting run in order and their output.

   sudo hive --service schemaTool -verbose -dbType mysql -upgradeSchema

   If you encounter any failures during this process and you want to upgrade your Hive Metastore by running the SQL yourself, refer to Upgrading Hive Metastore.

   If HDFS was used as storage for the Hive warehouse or any Hive DB location, you need to update the NameNode alias or URI with the new cluster’s HDFS alias.

9. Use the following commands to update the HDFS NameNode alias (replace <new-loc> <old-loc> with the HDFS root location of the new and old clusters, respectively):

   hive —service metatool -updateLocation <new-loc> <old-loc>

   You can run the following command on any EMR cluster node to get the HDFS NameNode alias:

   hdfs getconf -confKey dfs.namenode.rpc-address

   At first you can run with the dryRun option, which displays all the changes but aren’t persisted. For example:

   [hadoop@ip-172-31-87-188 ~]$ hive --service metatool -updateLocation hdfs://ip-172-31-50-80.ec2.internal:8020 hdfs://ip-172-31-87-188.ec2.internal:8020 -dryRun
   Initializing HiveMetaTool..
   Looking for LOCATION_URI field in DBS table to update..
   Dry Run of updateLocation on table DBS..
   old location: hdfs://ip-172-31-87-188.ec2.internal:8020/user/hive/warehouse/testdb.db new location: hdfs://ip-172-31-50-80.ec2.internal:8020/user/hive/warehouse/testdb.db
   old location: hdfs://ip-172-31-87-188.ec2.internal:8020/user/hive/warehouse/testdb_2.db new location: hdfs://ip-172-31-50-80.ec2.internal:8020/user/hive/warehouse/testdb_2.db
   old location: hdfs://ip-172-31-87-188.ec2.internal:8020/user/hive/warehouse new location: hdfs://ip-172-31-50-80.ec2.internal:8020/user/hive/warehouse
   Found 3 records in DBS table to update
   Looking for LOCATION field in SDS table to update..
   Dry Run of updateLocation on table SDS..
   old location: hdfs://ip-172-31-87-188.ec2.internal:8020/user/hive/warehouse/testtable1 new location: hdfs://ip-172-31-50-80.ec2.internal:8020/user/hive/warehouse/testtable1
   Found 1 records in SDS table to update

   However, if the new location needs to be changed to a different HDFS or S3 path, then use the following approach.

   First connect to the remote Hive Metastore database and run the following query to pull all the tables for a specific database and list the locations. Replace HiveMetastore_DB with the database name used for the Hive Metastore in the external database (for this post, hive) and the Hive database name (default):

   mysql> SELECT d.NAME as DB_NAME, t.TBL_NAME, t.TBL_TYPE, s.LOCATION FROM <HiveMetastore_DB>.TBLS t 
   JOIN <HiveMetastore_DB>.DBS d ON t.DB_ID = d.DB_ID JOIN <HiveMetastore_DB>.SDS s 
   ON t.SD_ID = s.SD_ID AND d.NAME='default';

   Identify the table for which location needs to be updated. Then run the Alter table command to update the table locations. You can prepare a script or chain of Alter table commands to update the locations for multiple tables.

   ALTER TABLE <table_name> SET LOCATION "<new_location>";

10. Start and check the status of Hive Metastore and HiveServer2:

    sudo systemctl start hive-hcatalog-server.service
    sudo systemctl start hive-server2.service
    sudo systemctl status hive-hcatalog-server.service
    sudo systemctl status hive-server2.service

Post-upgrade validation

Perform the following post-upgrade steps:

1. Confirm the Hive Metastore schema is upgraded to the new version:

   sudo hive --service schemaTool -dbType mysql -validate

   The output should look like the following code:

   Starting metastore validation
   
   Validating schema version
   Succeeded in schema version validation.
   [SUCCESS]
   Validating sequence number for SEQUENCE_TABLE
   Succeeded in sequence number validation for SEQUENCE_TABLE.
   [SUCCESS]
   Validating metastore schema tables
   Succeeded in schema table validation.
   [SUCCESS]
   Validating DFS locations
   Succeeded in DFS location validation.
   [SUCCESS]
   Validating columns for incorrect NULL values.
   Succeeded in column validation for incorrect NULL values.
   [SUCCESS]
   Done with metastore validation: [SUCCESS]
   schemaTool completed

2. Run the following Hive Schema Tool command to query the Hive schema version and verify that it’s upgraded:

   $ sudo hive --service schemaTool -dbType mysql -info
   Metastore connection URL:        jdbc:mysql://<host>:3306/<hivemetastore-dbname>?createDatabaseIfNotExist=true
   Metastore Connection Driver :    org.mariadb.jdbc.Driver
   Metastore connection User:       <username>
   Hive distribution version:       3.1.0
   Metastore schema version:        3.1.0

3. Run some DML queries against old tables and ensure they are running successfully.
4. Verify the table and database counts using the same commands mentioned in the prerequisites section, and compare the counts.

The Hive Metastore schema migration process is complete, and you can start working on your new EMR cluster. If for some reason you want to relaunch the EMR cluster, then you just need to provide the Hive Metastore remote database that we upgraded in the previous steps using the options on the Amazon EMR Configurations tab.

Migrate the Amazon EMR Hive Metastore to the AWS Glue Data Catalog

The AWS Glue Data Catalog is flexible and reliable, and can reduce your operation cost. Moreover, the Data Catalog supports different versions of EMR clusters. Therefore, when you migrate your Amazon EMR 5.X Hive Metastore to the Data Catalog, you can use the same Data Catalog with any new EMR 5.8+ cluster, including Amazon EMR 6.x. There are some factors you should consider when using this approach; refer to Considerations when using AWS Glue Data Catalog for more information. The following diagram shows the upgrade procedure.

To migrate your Hive Metastore to the Data Catalog, you can use the Hive Metastore migration script from GitHub. The following are the major steps for a direct migration.

Make sure all the table data is stored in Amazon S3 and not HDFS. Otherwise, tables migrated to the Data Catalog will have the table location pointing to HDFS, and you can’t query the table. You can check your table data location by connecting to the MySQL database and running the following SQL:

select SD_ID, LOCATION from SDS where LOCATION like 'hdfs%';

Make sure to complete the prerequisite steps mentioned earlier before proceeding with the migration. Ensure the EMR 5.X cluster is in a waiting state and all the components’ status are in service.

1. Note down the details of the existing EMR 5.X cluster Hive Metastore database to be upgraded.
   As mentioned before, this includes the endpoint host name, database name, user name, and password. You can do this through one of the following options:
   • Get the Hive Metastore DB information from the Hive configuration file – Log in to the Amazon EMR 5.X primary node, open the file /etc/hive/conf/hive-site.xml, and note the four properties:

   <property>
     <name>javax.jdo.option.ConnectionURL</name>
     <value>jdbc:mysql://{hostname}:3306/{dbname}?createDatabaseIfNotExist=true</value>
     <description>username to use against metastore database</description>
   </property>
   <property>
     <name>javax.jdo.option.ConnectionUserName</name>
     <value>{username}</value>
     <description>username to use against metastore database</description>
   </property>
   <property>
     <name>javax.jdo.option.ConnectionPassword</name>
     <value>{password}</value>
     <description>password to use against metastore database</description>
   </property>

   • Get the Hive Metastore DB information from the Amazon EMR console – Navigate to the Amazon EMR 5.X cluster, choose the Configurations tab, and note down the Metastore DB information.

   

2. On the AWS Glue console, create a connection to the Hive Metastore as a JDBC data source.
   Use the connection JDBC URL, user name, and password you gathered in the previous step. Specify the VPC, subnet, and security group associated with your Hive Metastore. You can find these on the Amazon EMR console if the Hive Metastore is on the EMR primary node, or on the Amazon RDS console if the Metastore is an RDS instance.
3. Download two extract, transform, and load (ETL) job scripts from GitHub and upload them to an S3 bucket:

   wget https://raw.githubusercontent.com/aws-samples/aws-glue-samples/master/utilities/Hive_metastore_migration/src/hive_metastore_migration.py
   wget https://raw.githubusercontent.com/aws-samples/aws-glue-samples/master/utilities/Hive_metastore_migration/src/import_into_datacatalog.py

   If you configured AWS Glue to access Amazon S3 from a VPC endpoint, you must upload the script to a bucket in the same AWS Region where your job runs.

   Now you must create a job on the AWS Glue console to extract metadata from your Hive Metastore to migrate it to the Data Catalog.

4. On the AWS Glue console, choose Jobs in the navigation pane.
5. Choose Create job.
6. Select Spark script editor.
7. For Options¸ select Upload and edit an existing script.
8. Choose Choose file and upload the import_into_datacatalog.py script you downloaded earlier.
9. Choose Create.
   
10. On the Job details tab, enter a job name (for example, Import-Hive-Metastore-To-Glue).
11. For IAM Role, choose a role.
12. For Type, choose Spark.
    
13. For Glue version¸ choose Glue 3.0.
14. For Language, choose Python 3.
15. For Worker type, choose G1.X.
16. For Requested number of workers, enter 2.
    
17. In the Advanced properties section, for Script filename, enter import_into_datacatalog.py.
18. For Script path, enter the S3 path you used earlier (just the parent folder).
    
19. Under Connections, choose the connection you created earlier.
    
20. For Python library path, enter the S3 path you used earlier for the file hive_metastore_migration.py.
21. Under Job parameters, enter the following key-pair values:
    • --mode: from-jdbc
    • --connection-name: EMR-Hive-Metastore
    • --region: us-west-2

    

22. Choose Save to save the job.
23. Run the job on demand on the AWS Glue console.

If the job runs successfully, Run status should show as Succeeded. When the job is finished, the metadata from the Hive Metastore is visible on the AWS Glue console. Check the databases and tables listed to verify that they were migrated correctly.

Known issues

In some cases where the Hive Metastore schema version is on a very old release or if some required metadata tables are missing, the upgrade process may fail. In this case, you can use the following steps to identify and fix the issue. Run the schemaTool upgradeSchema command with verbose as follows:

sudo hive --service schemaTool -verbose -dbType mysql -upgradeSchema

This prints all the queries being run in order and their output:

jdbc:mysql://metastore.xxxx.us-west-1> CREATE INDEX PCS_STATS_IDX ON PAR T_COL_STATS (DB_NAME,TABLE_NAME,COLUMN_NAME,PARTITION_NAME) USING BTREE
Error: (conn=6831922) Duplicate key name 'PCS_STATS_IDX' (state=42000,code=1061)
Closing: 0: jdbc:mysql://metastore.xxxx.us-west-1.rds.amazonaws.com:3306/hive?createDatabaseIfNotExist=true
org.apache.hadoop.hive.metastore.HiveMetaException: Schema initialization FAILED! Metastore state would be inconsistent !!
Underlying cause: java.io.IOException : Schema script failed, errorcode 2

Note down the query and the error message, then take the required steps to address the issue. For example, depending on the error message, you may have to create the missing table or alter an existing table. Then you can either rerun the schemaTool upgradeSchema command, or you can manually run the remaining queries required for upgrade. You can get the complete script that schemaTool runs from the following path on the primary node /usr/lib/hive/scripts/metastore/upgrade/mysql/ or from GitHub.

Clean up

Running additional EMR clusters to perform the upgrade activity in your AWS account may incur additional charges. When you complete the Hive Metastore upgrade successfully, we recommend deleting the additional EMR clusters to save cost.

Conclusion

To upgrade Amazon EMR from 5.X to 6.X and take advantage of some features from Hive 3.X or Spark SQL 3.X, you have to upgrade the Hive Metastore first. If you’re using the AWS Glue Data Catalog as your Hive Metastore, you don’t need to do anything because the Data Catalog supports both Amazon EMR versions. If you’re using a MySQL database as the external Hive Metastore, you can upgrade by following the steps outlined in this post, or you can migrate your Hive Metastore to the Data Catalog.

There are some functional differences between the different versions of Hive, Spark, and Flink. If you have some applications running on Amazon EMR 5.X, make sure test your applications in Amazon EMR 6.X and validate the function compatibility. We will cover application upgrades for Amazon EMR components in a future post.

About the authors

Jianwei Li is Senior Analytics Specialist TAM. He provides consultant service for AWS enterprise support customers to design and build modern data platform. He has more than 10 years experience in big data and analytics domain. In his spare time, he like running and hiking.

Narayanan Venkateswaran is an Engineer in the AWS EMR group. He works on developing Hive in EMR. He has over 17 years of work experience in the industry across several companies including Sun Microsystems, Microsoft, Amazon and Oracle. Narayanan also holds a PhD in databases with focus on horizontal scalability in relational stores.

Partha Sarathi is an Analytics Specialist TAM – at AWS based in Sydney, Australia. He brings 15+ years of technology expertise and helps Enterprise customers optimize Analytics workloads. He has extensively worked on both on-premise and cloud Bigdata workloads along with various ETL platform in his previous roles. He also actively works on conducting proactive operational reviews around the Analytics services like Amazon EMR, Redshift, and OpenSearch.

Krish is an Enterprise Support Manager responsible for leading a team of specialists in EMEA focused on BigData & Analytics, Databases, Networking and Security. He is also an expert in helping enterprise customers modernize their data platforms and inspire them to implement operational best practices. In his spare time, he enjoys spending time with his family, travelling, and video games.