Flink SQL访问DLF

前提条件

• 已创建Flink全托管工作空间。如未创建，详情请参见开通实时计算Flink版。

• 请确保Flink工作空间与DLF位于同一地域下，且添加Flink所在VPC为白名单，请参见配置VPC白名单。

使用限制

仅实时计算引擎VVR 11.1.0及以上版本支持对接DLF Catalog。

创建DLF Catalog

详情请参见 DLF 快速入门 。

在Flink上添加Catalog

1. 登录实时计算控制台。

2. 单击Flink全托管工作空间列表中的工作空间名称，进入对应的工作空间。

3. 可以通过UI或者SQL方式来添加Catalog。

   UI方式

   1. 在左侧导航栏，单击数据管理。

   2. 在Catalog列表页，单击创建Catalog。

   3. 选择Apache Paimon，单击下一步。

   4. metastore 选择 dlf，catalog name 选择需要关联版本的DLF Catalog，单击确定，即可创建Catalog。

   SQL命令

   在数据查询文本编辑区域，输入以下SQL并执行，即可创建Catalog。

   CREATE CATALOG `flink_catalog_name` 
   WITH (
     'type' = 'paimon',
     'metastore' = 'rest',
     'token.provider' = 'dlf',
     'uri' = 'http://cn-hangzhou-vpc.dlf.aliyuncs.com',
     'warehouse' = 'dlf_test'
   );

   参数说明如下：

   参数	描述	是否必填	示例
   type	Catalog类型，固定为paimon。	是	paimon
   metastore	metastore类型，固定为rest。	是	rest
   token.provider	Token提供方，固定为dlf。	是	dlf
   uri	访问DLF Rest Catalog Server的URI，格式为http://[region-id]-vpc.dlf.aliyuncs.com。详见地域与服务接入点中的Region ID。	是	http://cn-hangzhou-vpc.dlf.aliyuncs.com
   warehouse	DLF Catalog名称。	是	dlf_test

常见报错