Doris资源管理

恩慈2年前技术文章966

资源管理

为了节省Doris集群内的计算、存储资源,Doris需要引入一些其他外部资源来完成相关的工作,如Spark/GPU用于查询,HDFS/S3用于外部存储,Spark/MapReduce用于ETL, 通过ODBC连接外部存储等,因此我们引入资源管理机制来管理Doris使用的这些外部资源。

基本概念

一个资源包含名字、类型等基本信息,名字为全局唯一,不同类型的资源包含不同的属性,具体参考各资源的介绍。

资源的创建和删除只能由拥有 admin 权限的用户进行操作。一个资源隶属于整个Doris集群。拥有 admin 权限的用户可以将使用权限usage_priv 赋给普通用户。可参考HELP GRANT或者权限文档。

具体操作

资源管理主要有三个命令:CREATE RESOURCEDROP RESOURCESHOW RESOURCES,分别为创建、删除和查看资源。这三个命令的具体语法可以通过MySQL客户端连接到 Doris 后,执行 HELP cmd 的方式查看帮助。

  1. CREATE RESOURCE

    该语句用于创建资源。具体操作可参考 CREATE RESOURCE

  2. DROP RESOURCE

    该命令可以删除一个已存在的资源。具体操作见 DROP RESOURCE 。

  3. SHOW RESOURCES

    该命令可以查看用户有使用权限的资源。具体操作见 SHOW RESOURCES

支持的资源

目前Doris能够支持

  • Spark资源 : 完成ETL工作。

  • ODBC资源:查询和导入外部表的数据

下面将分别展示两种资源的使用方式。

Spark

参数

Spark 相关参数如下:

spark.master: 必填,目前支持yarn,spark://host:port。

spark.submit.deployMode: Spark 程序的部署模式,必填,支持 cluster,client 两种。

spark.hadoop.yarn.resourcemanager.address: master为yarn时必填。

spark.hadoop.fs.defaultFS: master为yarn时必填。

其他参数为可选,参考http://spark.apache.org/docs/latest/configuration.html

如果Spark用于ETL,还需要指定以下参数:

working_dir: ETL 使用的目录。spark作为ETL资源使用时必填。例如:hdfs://host:port/tmp/doris。

broker: broker 名字。spark作为ETL资源使用时必填。需要使用ALTER SYSTEM ADD BROKER 命令提前完成配置。

  • broker.property_key: broker读取ETL生成的中间文件时需要指定的认证信息等。

示例

创建 yarn cluster 模式,名为 spark0 的 Spark 资源。

CREATE EXTERNAL RESOURCE "spark0"
PROPERTIES
(
 "type" = "spark",
 "spark.master" = "yarn",
 "spark.submit.deployMode" = "cluster",
 "spark.jars" = "xxx.jar,yyy.jar",
 "spark.files" = "/tmp/aaa,/tmp/bbb",
 "spark.executor.memory" = "1g",
 "spark.yarn.queue" = "queue0",
 "spark.hadoop.yarn.resourcemanager.address" = "127.0.0.1:9999",
 "spark.hadoop.fs.defaultFS" = "hdfs://127.0.0.1:10000",
 "working_dir" = "hdfs://127.0.0.1:10000/tmp/doris",
 "broker" = "broker0",
 "broker.username" = "user0",
 "broker.password" = "password0"
);

ODBC

参数

ODBC 相关参数如下:

type: 必填,且必须为odbc_catalog。作为resource的类型标识。

user: 外部表的账号,必填。

password: 外部表的密码,必填。

host: 外部表的连接ip地址,必填。

port: 外部表的连接端口,必填。

odbc_type: 标示外部表的类型,当前doris支持mysqloracle,未来可能支持更多的数据库。引用该resource的ODBC外表必填,旧的mysql外表选填。

driver: 标示外部表使用的driver动态库,引用该resource的ODBC外表必填,旧的mysql外表选填。

示例

创建oracle的odbc resource,名为 odbc_oracle 的 odbc_catalog的 资源。

CREATE EXTERNAL RESOURCE `oracle_odbc`
PROPERTIES (
"type" = "odbc_catalog",
"host" = "192.168.0.1",
"port" = "8086",
"user" = "test",
"password" = "test",
"database" = "test",
"odbc_type" = "oracle",
"driver" = "Oracle 19 ODBC driver"
);

相关文章

nginx服务企业应用

1、软件的分类1.1 常用来提供静态服务的软件Apache :这是中小型Web服务的主流,Web服务器中的老大哥,Nginx :大型网站Web服务的主流,曾经Web服务器中的初生牛犊,现已长大。Ngi...

HDFS业务类型与相关架构优化措施

低延迟业务计算密集型业务,低延迟业务,这一类业务通常是对大量NameNode文件目录访问为主的(权限判断,文件存在性,文件信息查询等对NameNode元数据操作为主的)。因此需要针对NameNode的...

Alluxio部署

安装前准备1.1. 添加环境变量vi /etc/profile export ALLUXIO_HOME=/opt/alluxioexport PATH=$PATH:$ALLUXIO_HOME/bin ...

华为云SQLServer 慢日志查看

华为云SQLServer 慢日志查看

一、背景华为云目前只支持 SQLServer 登录数据库,不支持查看慢日志。对于开启慢日志的实例,也只能通过将慢日志下载到本地 再远程连接目标实例数据库查看。本篇将华为云 SQLServer 实例出现...

prometheus黑盒监控

prometheus黑盒监控

黑盒监控即以用户的身份测试服务的外部可见性,常见的黑盒监控包括 HTTP探针、TCP探针、Dns、Icmp等用于检测站点、服务的可访问性、服务的连通性,以及访问效率等。prometheus提供了bla...

A集群导入B集群中的高可用版rancher,一直处于pending状态

A集群导入B集群中的高可用版rancher,一直处于pending状态

问题现象:已知在B集群中采用helm方式部署了一个高可用版本的rancher,该rancher中已经配置导入了三套集群,并且三套集群状态在rancher控制台处均显示正常,日常可借助该rancher管...

发表评论    

◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。