基础使用

MapReduce BMR

  • 发行版本
  • 功能发布记录
  • 产品描述
    • 节点类型说明
    • 产品优势
    • 应用场景
    • 产品功能
    • 产品简介
  • Python-SDK
    • Cluster(集群)
    • BmrClient
    • 异常处理
    • InstanceGroup(实例组)
    • 简介
    • 文档更新记录
    • Step(作业)
    • 版本变更记录
    • Instance(实例)
    • 快速入门
    • 安装SDK工具包
  • 开源组件介绍
    • Impala
    • Pig
    • Druid
    • Presto
    • Hue
    • Ooize
    • HBase
    • Kudu
    • Sqoop
    • Hadoop-Streaming
    • Zeppelin
    • Alluxio
    • Kerberos
      • 集群互信配置
      • 概述
    • ClickHouse
      • 常见问题
      • 数据迁移同步
        • 从Spark导入
        • 从Kafka同步数据
        • 将自建ClickHouse数据迁移到云ClickHouse中
        • 从Flink导入
        • 从MySQL导入和同步
        • 从本地数据导入
          • Parquet格式
          • JSON
          • SQL转储
          • CSV and TSV
      • 快速入门
        • 访问模式
        • 客户端登录
        • 创建ClickHouse集群
        • 基础操作
      • 运维相关操作
        • ClickHouse集群扩容
        • ClickHouse集群缩容
        • 日志配置说明
        • 监控告警配置
    • Ranger
      • ranger概述
      • 权限策略配置
    • Paimon
      • Hive示例
      • StarRocks示例
      • 联合查询示例
      • Flink示例
      • Spark示例
    • Flink
      • 基础使用
    • Trino
      • 基础使用
      • 概述
    • Spark
      • 引擎增强
      • 基础使用
    • Hive
      • 开发指南
        • 自定义函数(UDF)
      • 实践操作
        • Hive迁移
        • Hive操作HBase外表
      • 基础使用
        • Hive基础操作
        • Hive连接方式
  • Java-SDK
    • Cluster(集群)
    • 异常
    • BmrClient
    • InstanceGroup(实例组)
    • 日志
    • 文档更新记录
    • 版本更新记录
    • Step(作业)
    • Instance(实例)
    • 快速入门
    • 安装SDK工具包
    • 概述
  • 快速入门
    • 操作流程概览
    • 环境准备
    • 创建集群
    • 数据准备
    • 开发作业
    • 查看结果
    • ClickHouse
      • 导入数据
      • 创建数据库
      • 连接集群
      • 创建表
  • 操作指南
    • 集群模板
    • 服务管理
    • 集群配置
      • 用户管理
      • 弹性伸缩
      • 创建集群
      • 集群安全模式
      • EIP
      • Hive元数据说明
      • 集群审计
      • 配置已有集群
      • 安全组
    • 管理作业
      • 创建作业
      • 诊断、调优
      • 定时任务
      • 查看作业
    • 访问集群
      • 访问集群服务页面
      • 访问集群-openVPN访问集群
      • 使用OpenVPN提交Hadoop作业
      • SSH连接到集群
    • 实践操作
      • 存储数据至HBase
      • 导入数据
      • 编译Maven项目
      • Sqoop导入导出数据
        • 导出数据
    • 权限管理
      • 多用户访问控制
      • 用户管理
    • 集群管理
      • 节点管理
      • 监控报警
      • 集群指标
      • 资源管理
  • 服务等级协议SLA
    • BMR服务等级协议SLA
  • API参考
    • 通用说明
    • 公共头
    • 数据类型
    • 版本更新记录
    • 服务域名
    • 实例操作接口
    • 实例组操作接口
    • 集群操作接口
    • API简介
    • 错误码
  • 常见问题
    • 安全性问题
    • 计费类问题
    • 常见问题总览
    • 性能类问题
    • 配置类问题
    • 故障类问题
  • 视频专区
    • 操作指南
    • 产品介绍
  • 场景教程
    • 流式应用场景
    • 离线应用场景
    • 使用Hive分析网站日志
    • Sqoop应用文档
    • 定时分析日志数据
    • HIVE
      • 不同集群的 Hive 迁移方案
      • Hive 操作 Hbase 外部表
  • 产品定价
    • 转换计费方式
    • 计费项
    • 到期或欠费说明
    • 包年包月计费
    • 续费说明
    • 变更配置计费说明
    • 计费方式
    • 按需计费
    • 账单和用量查询
    • 退款说明
所有文档
menu
没有找到结果,请重新输入

MapReduce BMR

  • 发行版本
  • 功能发布记录
  • 产品描述
    • 节点类型说明
    • 产品优势
    • 应用场景
    • 产品功能
    • 产品简介
  • Python-SDK
    • Cluster(集群)
    • BmrClient
    • 异常处理
    • InstanceGroup(实例组)
    • 简介
    • 文档更新记录
    • Step(作业)
    • 版本变更记录
    • Instance(实例)
    • 快速入门
    • 安装SDK工具包
  • 开源组件介绍
    • Impala
    • Pig
    • Druid
    • Presto
    • Hue
    • Ooize
    • HBase
    • Kudu
    • Sqoop
    • Hadoop-Streaming
    • Zeppelin
    • Alluxio
    • Kerberos
      • 集群互信配置
      • 概述
    • ClickHouse
      • 常见问题
      • 数据迁移同步
        • 从Spark导入
        • 从Kafka同步数据
        • 将自建ClickHouse数据迁移到云ClickHouse中
        • 从Flink导入
        • 从MySQL导入和同步
        • 从本地数据导入
          • Parquet格式
          • JSON
          • SQL转储
          • CSV and TSV
      • 快速入门
        • 访问模式
        • 客户端登录
        • 创建ClickHouse集群
        • 基础操作
      • 运维相关操作
        • ClickHouse集群扩容
        • ClickHouse集群缩容
        • 日志配置说明
        • 监控告警配置
    • Ranger
      • ranger概述
      • 权限策略配置
    • Paimon
      • Hive示例
      • StarRocks示例
      • 联合查询示例
      • Flink示例
      • Spark示例
    • Flink
      • 基础使用
    • Trino
      • 基础使用
      • 概述
    • Spark
      • 引擎增强
      • 基础使用
    • Hive
      • 开发指南
        • 自定义函数(UDF)
      • 实践操作
        • Hive迁移
        • Hive操作HBase外表
      • 基础使用
        • Hive基础操作
        • Hive连接方式
  • Java-SDK
    • Cluster(集群)
    • 异常
    • BmrClient
    • InstanceGroup(实例组)
    • 日志
    • 文档更新记录
    • 版本更新记录
    • Step(作业)
    • Instance(实例)
    • 快速入门
    • 安装SDK工具包
    • 概述
  • 快速入门
    • 操作流程概览
    • 环境准备
    • 创建集群
    • 数据准备
    • 开发作业
    • 查看结果
    • ClickHouse
      • 导入数据
      • 创建数据库
      • 连接集群
      • 创建表
  • 操作指南
    • 集群模板
    • 服务管理
    • 集群配置
      • 用户管理
      • 弹性伸缩
      • 创建集群
      • 集群安全模式
      • EIP
      • Hive元数据说明
      • 集群审计
      • 配置已有集群
      • 安全组
    • 管理作业
      • 创建作业
      • 诊断、调优
      • 定时任务
      • 查看作业
    • 访问集群
      • 访问集群服务页面
      • 访问集群-openVPN访问集群
      • 使用OpenVPN提交Hadoop作业
      • SSH连接到集群
    • 实践操作
      • 存储数据至HBase
      • 导入数据
      • 编译Maven项目
      • Sqoop导入导出数据
        • 导出数据
    • 权限管理
      • 多用户访问控制
      • 用户管理
    • 集群管理
      • 节点管理
      • 监控报警
      • 集群指标
      • 资源管理
  • 服务等级协议SLA
    • BMR服务等级协议SLA
  • API参考
    • 通用说明
    • 公共头
    • 数据类型
    • 版本更新记录
    • 服务域名
    • 实例操作接口
    • 实例组操作接口
    • 集群操作接口
    • API简介
    • 错误码
  • 常见问题
    • 安全性问题
    • 计费类问题
    • 常见问题总览
    • 性能类问题
    • 配置类问题
    • 故障类问题
  • 视频专区
    • 操作指南
    • 产品介绍
  • 场景教程
    • 流式应用场景
    • 离线应用场景
    • 使用Hive分析网站日志
    • Sqoop应用文档
    • 定时分析日志数据
    • HIVE
      • 不同集群的 Hive 迁移方案
      • Hive 操作 Hbase 外部表
  • 产品定价
    • 转换计费方式
    • 计费项
    • 到期或欠费说明
    • 包年包月计费
    • 续费说明
    • 变更配置计费说明
    • 计费方式
    • 按需计费
    • 账单和用量查询
    • 退款说明
  • 文档中心
  • arrow
  • MapReduceBMR
  • arrow
  • 开源组件介绍
  • arrow
  • Trino
  • arrow
  • 基础使用
本页目录
  • 前提条件
  • 元数据管理
  • 连接Trino进行查询
  • 元数据管理为DEFAULT
  • 元数据管理为EDAP
  • 连接安全模式集群
  • 查看日志

基础使用

更新时间:2025-08-21

前提条件

  • 已创建 Hadoop 类型集群,并选择了 Trino 服务,创建集群详情请参见创建集群。或者 已创建 Trino 类型集群。
  • 如需使用 EDAP 统一元数据管理,请开通 EDAP 产品使用权限。

元数据管理

Trino支持有两种元数据管理方式,一种是使用 DEFAULT 元数据管理,一种是使用 EDAP 元数据管理。

  • DEFAULT 元数据管理:默认的数据源是本集群 Hive Meta Store,若要查询其它数据源,需要在集群上手动添加 connector 配置文件到${TRINO_HOME}/etc/catalog目录下并同步到所有节点,然后重启 Trino 服务,参考官网文档。
  • EDAP 元数据管理:当使用EDAP 元数据管理时,需要在edap中添加数据源,trino服务对数据源实行动态加载,不需要重启服务。

连接Trino进行查询

元数据管理为DEFAULT

  1. SSH登录集群 Core / Coordinator节点 ,参考SSH连接到集群
  2. 执行以下命令,切换用户:
Plain Text
1su hdfs
  1. 执行以下命令进入交互式命令行:
Plain Text
1/opt/bmr/trino/bin/trino \
2--server https://{coordinator_host}:8089 
  1. 执行以下命令,连接到数据库:
Plain Text
1use hive.default;
  1. 创建表示例:
Plain Text
1create table test(id bigint, name varchar); 
  1. 插入数据示例:
Plain Text
1insert into test values(1,'aa'),(2,'bb');
  1. 查询数据示例:
Plain Text
1select * from test; 

元数据管理为EDAP

  1. SSH登录集群 Core / Coordinator节点 ,参考SSH连接到集群
  2. 执行以下命令,切换用户:
Plain Text
1su hdfs
  1. 执行以下命令进入交互式命令行:
Plain Text
1/opt/bmr/trino/bin/trino \
2--server http://{coordinator_host}:8089 \
3--catalog edap_physical_tbl \
4--extra-credential access_key={accessKey} \      // accessKey的是/etc/hadoop/conf/core-site.xml fs.bos.access.key
5--extra-credential secret_key={accessSecret} \   // accessSecret的是/etc/hadoop/conf/core-site.xml fs.bos.secret.access.key
6--extra-credential session_token_key="{token}"   // token的是/etc/hadoop/conf/core-site.xml fs.bos.session.token.key
  1. 执行以下命令,连接到数据库:
Plain Text
1use edap_physical_tbl.{database};
  1. 查询 EDAP 管理的表示例:
Plain Text
1select * from test; 

连接安全模式集群

BMR 支持创建安全模式的 Hadoop / Trino 集群,连接安全模式集群时,需要使用https协议访问7778端口,还需要添加安全认证参数。示例如下:

Plain Text
1/opt/bmr/trino/bin/trino \
2// ${coordinator_host}请使用CanonicalHostName,同/opt/bmr/trino/etc/config.properties http-server.authentication.krb5.principal-hostname
3--server https://{coordinator_host}:7778 \   
4--krb5-config-path /etc/krb5.conf   \
5// 可以执行`klist -kt /etc/security/keytabs/hdfs.headless.keytab`获取
6--krb5-principal hdfs@BAIDU.COM   \  
7--krb5-keytab-path /etc/security/keytabs/hdfs.headless.keytab   \
8--krb5-remote-service-name trino   \
9--keystore-path /etc/security/keytabs/keystore.jks  \
10--keystore-password {http-server.https.keystore.key} \   // http-server.https.keystore.key的值在/opt/bmr/trino/etc/config.properties中
11--user hdfs@BAIDU.COM \

查看日志

  1. 通过 百度云 BMR 控制台 集群列表>>集群详情>>相关应用和工具>>Trino Url,进入Trino UI。

image (10).png

  1. 通过页面的state选项可以对查询任务进行筛选。

image (11).png

  1. 点击查询编号,可以进一步查看查询详情和报错日志.

image (12).png

image (13).png

上一篇
Flink
下一篇
概述