# FlinkServer数据管理
#### 约束与限制
- 数据管理仅支持创建表和删除表。
- 单次请求只能执行单条SQL。
- 自定义Connector的表类型不支持通过数据管理模块创建对应表。
- 本章节适用于MRS 3.6.0-LTS.1及以后版本。
 
#### 操作步骤
1. 访问Flink WebUI，请参考[访问FlinkServer WebUI界面](https://support.huaweicloud.com/cmpntguide-lts-mrs/mrs_01_24019.html)。

2. 单击"数据管理"，下拉框选择创建好的Catalog，具体操作请参考[FlinkServer Catalog管理](https://support.huaweicloud.com/cmpntguide-lts-mrs/mrs_01_300802.html#mrs_01_300802)，会自动带出Catalog包含的库和表。
3. 构造建表语句: 
   - 在hive_catalog、default数据库中创建名称为"hive_table"的hive表，完整示例如下：
     ```
     create table if not exists hive_catalog.`default`.hive_table (
       user_id STRING,
       item_id STRING,
       cat_id STRING,
       ts timestamp(9),
       dy STRING,
       ho STRING,
       mi STRING
     ) PARTITIONED BY (dy, ho, mi)
     with
       (
         'connector' = 'hive',
         'partition.time-extractor.timestamp-pattern' = '$dy $ho:$mi:00',
         'sink.partition-commit.trigger' = 'process-time',
         'sink.partition-commit.delay' = '0S',
         'sink.partition-commit.policy.kind' = 'metastore,success-file'
       );
     ```
     
   
   
   
   - 在hudi_catalog、default数据库中创建名称为"hudi_table"的hudi表，完整示例如下：
     ```
     create table if not exists hudi_catalog.`default`.hudi_table (
       uuid VARCHAR(20),
       name VARCHAR(10),
       age INT,
       ts INT,
       `p` VARCHAR(20)
     ) PARTITIONED BY (`p`)
     WITH
       (
         'connector' = 'hudi',
         'path' = 'hdfs://hacluster/tmp/hudi/hudi_table',
         'table.type' = 'MERGE_ON_READ',
         'hoodie.datasource.write.recordkey.field' = 'uuid',
         'index.type' = 'BUCKET',
         'hoodie.bucket.index.num.buckets' = '4',
         'write.precombine.field' = 'ts',
         'write.tasks' = '4'
       );
     ```
     
   
   
   
   - 在iceberg_catalog、default数据库中创建名称为"iceberg_table"的iceberg表，完整示例如下：
     ```
     CREATE TABLE if not exists iceberg_catalog.`default`.iceberg_table (
       id BIGINT COMMENT 'unique id',
       data STRING NOT NULL
     ) PARTITIONED BY (data)
     WITH
       ('format-version' = '2');
     ```
     
   
   
   
   
4. 单击左上角的"执行SQL"，可在"SQL执行历史"界面查看SQL执行情况，包括执行用户、执行SQL、执行结果和执行时间。
5. 如果执行SQL失败，可单击"执行用户"旁边的![](https://support.huaweicloud.com/cmpntguide-lts-mrs/zh-cn_image_0000002569826519.png "点击放大")，通过"执行失败原因"查看失败详情。