苍溪规划和建设局网站重庆住房城乡建设部网站

使用 Flink Doris Connector 可以实时的将 Flink 产生的数据（如：Flink 读取 Kafka，MySQL 中的数据）导入到 Doris 中。

使用限制​

需要依赖用户部署的 Flink 集群。

使用 Flink 导入数据​

使用 Flink 导入数据，详细步骤可以参考 Flink-Doris-Connector。在以下步骤中，演示如何通过 Flink 快速导入数据。

第 1 步：创建表​

CREATE TABLE `students` (`id` INT NULL, `name` VARCHAR(256) NULL,`age` INT NULL
) ENGINE=OLAP
UNIQUE KEY(`id`)      
COMMENT 'OLAP' 
DISTRIBUTED BY HASH(`id`) BUCKETS 1  
PROPERTIES (                                                         
"replication_allocation" = "tag.location.default: 1"
); 

第 2 步：使用 Flink 导入数据​

运行 bin/sql-client.sh 打开 FlinkSQL 的控制台

CREATE TABLE student_sink (id INT,name STRING,age INT) WITH ('connector' = 'doris','fenodes' = '10.16.10.6:28737','table.identifier' = 'test.students','username' = 'root','password' = '','sink.label-prefix' = 'doris_label'
);INSERT INTO student_sink values(1,'zhangsan',123)

第 3 步：检查导入数据​

mysql> select * from test.students;                                                                                                                        
+------+----------+------+      
| id   | name     | age  |    
+------+----------+------+                                                                                                                             
|  1   | zhangsan |  123 |   
+------+----------+------+    
1 rows in set (0.05 sec)