安裝
下載安裝包
presto官網:https://prestodb.io/
- presto-server下載連接:https://repo1.maven.org/maven2/com/facebook/presto/presto-server/0.248/presto-server-0.248.tar.gz
- presto-cli客戶端下載連接:https://repo1.maven.org/maven2/com/facebook/presto/presto-cli/0.248/presto-cli-0.248-executable.jar
- JDBC DRIVER 下載連接:https://repo1.maven.org/maven2/com/facebook/presto/presto-jdbc/0.248/presto-jdbc-0.248.jar
解壓presto-server包
tar -zxvf presto-server-0.248.tar.gz
文件目錄結構如下
drwxr-xr-x 3 rong rong 4096 Mar 29 10:29 bin
drwxrwxr-x 2 rong rong 12288 Mar 29 09:54 lib
-rw-r--r-- 1 rong rong 191539 Mar 5 02:48 NOTICE
drwxrwxr-x 33 rong rong 4096 Mar 29 09:54 plugin
-rw-r--r-- 1 rong rong 126 Mar 5 02:48 README.txt
創建etc目錄
mkdir etc
結構如下:
drwxr-xr-x 3 rong rong 4096 Mar 29 10:29 bin
drwxrwxr-x 3 rong rong 4096 Mar 29 15:08 etc
drwxrwxr-x 2 rong rong 12288 Mar 29 09:54 lib
-rw-r--r-- 1 rong rong 191539 Mar 5 02:48 NOTICE
drwxrwxr-x 33 rong rong 4096 Mar 29 09:54 plugin
-rw-r--r-- 1 rong rong 126 Mar 5 02:48 README.txt
在etc目錄創建需要配置文件
1. 創建config.propertie
touch config.properties
內容如下:
# 指定是否運維Presto實例作為一個coordinator(接收來自客戶端的查詢情切管>理每個查詢的執行過程)
coordinator=true
# 是否允許在coordinator服務中進行調度工作,
node-scheduler.include-coordinator=true
http-server.http.port=8080
query.max-memory=100MB
query.max-memory-per-node=100MB
query.max-total-memory-per-node=100MB
discovery-server.enabled=true
discovery.uri=http://dx-dev-test1028:8080
# 如果節點是worker 則是以下配置
# coordinator=false
# http-server.http.port=8080
# query.max-memory=50GB
# query.max-memory-per-node=1GB
# query.max-total-memory-per-node=2GB
# discovery.uri=http://example.net:8080
~
2. 創建jvm.config
touch jvm.config
內容如下:
-server
-Xmx500M
-XX:+UseG1GC
-XX:G1HeapRegionSize=32M
-XX:+UseGCOverheadLimit
-XX:+ExplicitGCInvokesConcurrent
-XX:+HeapDumpOnOutOfMemoryError
-Djava.security.krb5.conf=/etc/krb5.conf
注意:如果集群沒有集成kerberos,配置最后一行需要去掉。
3. 創建log.properties
配置日志級別
touch log.properties
內容如下:
com.facebook.presto=INFO
4. 創建node.properties
touch node.properties
內容如下:
# 集群名稱, 所有在同一個集群中的Presto節點必須擁有相同的集群名稱
node.environment=production
# 每個Presto節點的唯一標示。每個節點的node.id都必須是唯一的
node.id=dx-dev-test1028
#該路徑要自己創建 隨意的目錄
node.data-dir=/var/presto/data
在etc目錄下創建catlog目錄
mkdir catalog
在catalog目錄下配置數據源
1. 配置mysql數據源
touch mysql.properties
內容如下:
connector.name=mysql
connection-url=jdbc:mysql://dx-dev-test1028:3306
connection-user=root
connection-password=root
2. 配置hive數據源(沒權限)
touch hive.properties
內容如下:
# name后面為固定寫法
connector.name=hive-hadoop2
# 需要啟動hive metastore服務
hive.metastore.uri=thrift://dx-dev-test1026:9083
# hadoop集群的配置文件目錄
hive.config.resources=${HADOOP_HOME}/etc/hadoop/core-site.xml,${HADOOP_HOME}/etc/hadoop/hdfs-site.xml
客戶端配置
將客戶端放到 ${PRESTO_HOME}/bin 下:
mv presto-cli-0.248-executable.jar ${PRESTO_HOME}/bin
修改名稱為 presto ,並賦予執行權限 chmod +x
mv presto-cli-0.248-executable.jar presto
# 賦權執行權限
chmod +x presto
測試
--啟動服務
bin/launcher run
--啟動客戶端
./presto --server hadoop001:8080 --catalog myslq
集成kerberos
生成persto主體的princal
kadmin.local -q "addprinc -randkey presto/admin@RONG360.COM"
kadmin.local -q "xst -norandkey -k presto.keytab presto/admin@RONG360.COM"
集成Kerberos環境Hive
1. 修改hive.properties
connector.name=hive-hadoop2
#需要啟動hive metastore服務
hive.metastore.uri=thrift://dx-dev-test1026:9083
#配置Presto訪問HiveMetastore服務的Kerberos信息,該段配置可以只存在Presto的Coordinator節點
hive.metastore.authentication.type=KERBEROS
hive.metastore.service.principal=hive/_HOST@RONG360.COM
hive.metastore.client.principal=presto/admin@RONG360.COM
hive.metastore.client.keytab=/root/presto.keytab
#配置Presto訪問HDFS的Kerberos信息,改段配置可以只存在Presto的Worker節點
hive.hdfs.authentication.type=KERBEROS
hive.hdfs.impersonation.enabled=true
hive.hdfs.presto.principal=presto/admin@RONG360.COM
hive.hdfs.presto.keytab=/root/presto.keytab
# hadoop集群的配置文件目錄
hive.config.resources=/etc/hadoop/conf/core-site.xml,/etc/hadoop/conf/hdfs-site.xml
在hive.properties配置文件中增加訪問HiveMetastore和HDFS的Kerberos認證信息,將如上配置同步至Presto集群所有節點的${PRESTO_HOME}/etc/catalog/hive.properties文件中。
注意:在配置hive.metastore.url時,需要使用HiveMetastore服務的HOSTNAME,否則在使用Kerberos訪問HiveMetastore時會報找不到Kerberos賬號的錯誤。
2. 修改config.properties
-server
-Xmx500M
-XX:+UseG1GC
-XX:G1HeapRegionSize=32M
-XX:+UseGCOverheadLimit
-XX:+ExplicitGCInvokesConcurrent
-XX:+HeapDumpOnOutOfMemoryError
-Djava.security.krb5.conf=/etc/krb5.conf
注意:最后一行
3. 配置HDFS
修改core-site.xml
<property>
<name>hadoop.proxyuser.presto.hosts</name>
<value>*</value>
</property>
<property><name>hadoop.proxyuser.presto.groups</name>
<value>*</value>
</property>
4. 重啟HDFS 和 presto
./bin/launcher restart
測試
presto --server http://dx-dev-test1028:8080 --catalog hive --schema default
測試命令1:
show schemas;
內容如下:
Schema
--------------------
default
information_schema
test
(3 rows)
測試命令2:
select * from mysql.test.student_mysql a left join hive.test.student_txt b on a.name=b.name;
結果如下:
id | name | name | age
----+--------+--------+-----
1 | lisi | lisi | 15
(1 row)
測試成功!