全部产品

Flink AnalyticDB MySQL Connector

更新时间:2021-04-20 13:56:56

本文以示例形式介绍如何将开源Flink中的数据写入到AnalyticDB MySQL

操作步骤

  1. 本文支持如下版本的jar包,请单击对应链接下载。

  2. 将所有Flink节点/home/admin/flink-1.10.1/lib下的flink-jdbc_2.11-1.10.1.jar文件替换为步骤1中下载的jar包。

  3. 重启所有Flink节点。

  4. 在Flink中创建AnalyticDB MySQL表,需要加上AnalyticDB MySQL的dialect。

CREATE TABLE table_test (
 col1 VARCHAR,
 col2 BIGINT,
 col3 BIGINT
) WITH (
 'connector.type' = 'jdbc', -- 使用 jdbc connector
 'connector.dialect' = 'adb', -- 使用connector dialect
 'connector.url' = 'jdbc:mysql://ip:port/db_name', -- jdbc url
 'connector.table' = 'table_name', -- 表名
 'connector.username' = 'xxx', -- AnalyticDB MySQL账号名
 'connector.password' = 'xxx', -- AnalyticDB MySQL账号名对应的密码
);

更多Flink信息,请参见Flink