Dinky Docker 开启 FlinkSQL 丝滑之旅

Dinky开源 2023-03-09

2641

摘要：本文介绍了如何通过 Docker 一键快速部署 Dinky 来开启 FlinkSQL 丝滑之旅。内容包括：

Dinky 介绍
Dinky 主要功能
Dinky 核心优势
Docker 快速体验
入门示例
结束语

Tips：历史传送门～

《Dinky CDCSOURCE 整库同步实践汇总》

《Dinky在Doris实时整库同步和模式演变的探索实践》

GitHub 地址

https://github.com/DataLinkDC/dinky

https://gitee.com/DataLinkDC/Dinky

欢迎大家关注 Dinky 的发展~

一、Dinky 介绍

一个开箱即用、易扩展，以 Apache Flink 为基础，连接 OLAP 和数据湖等众多框架的一站式实时计算平台，致力于流批一体和湖仓一体的探索与实践。

二、Dinky 主要功能

三、Dinky 核心优势

四、Docker 快速体验

通过 dinky-mysql-server 和 dinky-standalone-server 镜像快速体验 Flink 实时计算平台。

环境准备

需要 Docker 1.13.1+
。

启动 dinky-mysql-server 镜像

启动该镜像提供 Dinky 的 Mysql 业务库能力。

docker run --name dinky-mysql dinkydocker/dinky-mysql-server:0.7.2

见以下内容证明启动成功：

2023-03-08T12:04:23.520202Z 0 [Note] mysqld: ready for connections.
Version: '5.7.41'  socket: '/var/run/mysqld/mysqld.sock'  port: 3306  MySQL Community Server (GPL)

启动 dinky-standalone-server 镜像

启动该镜像提供 Dinky 实时计算平台。

docker run --restart=always -p 8888:8888 -p 8081:8081  -e MYSQL_ADDR=dinky-mysql:3306 --name dinky --link dinky-mysql:dinky-mysql dinkydocker/dinky-standalone-server:0.7.2-flink14

见以下内容证明启动成功：

Dinky pid is not exist in opt/dinky/run/dinky.pid
FLINK VERSION : 1.14
........................................Start Dinky Successfully........................................
........................................Restart Successfully........................................

如果 docker image
需要加速，请把 dinkydocker
替换成 registry.cn-hangzhou.aliyuncs.com/dinky
。

五、入门示例

创建作业

IP:8888
地址打开平台并 admin/admin
登录，创建 功能示例
目录，创建 HelloWorld
的 FlinkSQL 作业。

执行模式选择 Local
并输入以下语句：

CREATE TABLE Orders (
    order_number BIGINT,
    price        DECIMAL(32,2),
    buyer        ROW<first_name STRING, last_name STRING>,
    order_time   TIMESTAMP(3)
) WITH (
  'connector' = 'datagen',
  'rows-per-second' = '1',
  'number-of-rows' = '50'
);
select order_number,price,first_name,last_name,order_time from Orders