使用OmniAdvisor参数调优特性计算出Hive任务的最佳运行参数,从而优化任务性能。
vi $HIVE_HOME/conf/hive-site.xml
1 2 3 4 5 6 7 8 9 10 11 12 | <property> <name>hive.execution.engine</name> <value>tez</value> </property> <property> <name>hive.cli.tez.session.async</name> <value>false</value> <description> Whether to start Tez session in background when running CLI with Tez, allowing CLI to be available earlier. </description> </property> |
1 | vi /opt/OmniAdvisor/BoostKit-omniadvisor_1.0.0/config/common_config.cfg
|
1 2 3 4 5 | [database] # MySQL数据库相关的用户名,端口号等信息 db_name = test_hive db_host = localhost db_port = 3306 |
1 | python main.pyc hive init_environment |
执行成功后,会在test_hive数据库中创建yarn_app_result、best_config和sampling_config表。
1 | vi /opt/OmniAdvisor/boostkit-omniadvisor-log-analyzer-1.0.0-aarch64/conf/omniAdvisorLogAnalyzer.properties
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 | # 日志解析并发进程数 log.analyzer.thread.count=3 # 数据库的Driver,目前只支持MySQL datasource.db.driver=com.mysql.cj.jdbc.Driver # 数据库的URL datasource.db.url=jdbc:mysql://server1:3306/database # 是否开启Tez的日志解析 tez.enable=true # Hive Tez的工作DataBase tez.workload=default # timeline服务的URL tez.timeline.url=http://server1:8188 # timeline服务连接超时时间,单位:ms tez.timeline.timeout.ms=6000 # 安全模式下用于kerberos认证的用户,非安全模式环境可省略 kerberos.principal=principle # 安全模式下用于kerberos认证的keytab文件路径,非安全模式环境可省略 kerberos.keytab.file=/usr/principle.keytab |
cp ${HADOOP_HOME}/etc/hadoop/hdfs-site.xml /opt/OmniAdvisor/boostkit-omniadvisor-log-analyzer-1.0.0-aarch64/conf cp ${HADOOP_HOME}/etc/hadoop/core-site.xml /opt/OmniAdvisor/boostkit-omniadvisor-log-analyzer-1.0.0-aarch64/conf
1 | vi /opt/OmniAdvisor/BoostKit-omniadvisor_1.0.0/config/common_config.cfg
|
1 2 3 4 5 6 7 | [hive] # Tez运行日志的起始时间,可以从Hadoop UI上查看日期 log_start_time = 2023-09-14 19:12:45 # Tez运行日志的终止时间 log_end_time = 2023-09-14 19:19:45 # 是否对已经运行过的SQL进行全部采样(从数据库中获取application_name),如果为true,则history_application_name配置项会失效 enable_sampling_all_sql = true |
1 | python main.pyc hive fetch_history_data |
数据解析成功后,将数据结果写入了yarn_app_result表和best_config表中,sampling_config表中仍是空的。
1 | vi /opt/OmniAdvisor/BoostKit-omniadvisor_1.0.0/config/common_config.cfg
|
1 2 3 4 5 | [sampling] # 参数采样的轮数 sampling_epochs = 40 [hive] enable_sampling_all_sql = true |
1 | python main.pyc hive parameter_sampling |
执行成功后可以在数据库中的sampling_config表查看到采样的数据。
1 | vi /opt/OmniAdvisor/BoostKit-omniadvisor_1.0.0/config/common_config.cfg
|
1 2 3 4 5 6 | [sampling] # 参数采样的轮数 sampling_epochs = 40 [hive] enable_sampling_all_sql = false history_application_name=q12 |
1 | python main.pyc hive parameter_sampling |
执行成功后可以在数据库中的sampling_config表查看到采样的数据。
rm -rf $HIVE_HOME/bin/hive-recommend cp $HIVE_HOME/bin/hive $HIVE_HOME/bin/hive-recommend
1 | vi hive-recommend
|
1 | $TORUN "$@"
|
1 | python /opt/OmniAdvisor/BoostKit-omniadvisor_1.0.0/main.pyc hive parameter_recommend "$@" |
1 | vi /opt/OmniAdvisor/BoostKit-omniadvisor_1.0.0/config/common_config.cfg
|
1 2 3 4 | [recommend] # 任务采样调优完成后,需要重新运行某个历史任务,可以通过任务的名称(application_name)或者query的Hash值(query_hash)来指定查找数据库中该任务的最佳参数 # options: [application_name, query_hash] recommend_identifier = application_name |
$HIVE_HOME/bin/hive-recommend --hiveconf hive.tez.container.size=1024 --hiveconf tez.am.resource.memory.mb=1024 --hiveconf hive.session.id=q12 --database tpcds_bin_partitioned_decimal_orc_3000 -f /home/test_hive/q12.sql
1 | vi /opt/OmniAdvisor/BoostKit-omniadvisor_1.0.0/config/common_config.cfg
|
1 2 3 4 | [recommend] # 任务采样调优完成后,需要重新运行某个历史任务,可以通过任务的名称(application_name)或者query的Hash值(query_hash)来指定查找数据库中该任务的最佳参数 # options: [application_name, query_hash] recommend_identifier = query_hash |
$HIVE_HOME/bin/hive-recommend --hiveconf hive.tez.container.size=1024 --hiveconf tez.am.resource.memory.mb=1024 --hiveconf hive.session.id=q12_bak --database tpcds_bin_partitioned_decimal_orc_3000 -f /home/test_hive/q12.sql