Unverified Commit 48a0fdbd authored by aiwenmo's avatar aiwenmo Committed by GitHub

[Document-326][doc] Modify introduction and concept and feature

[Document-326][doc] Modify introduction and concept and feature
parents 05c23841 064b2546
...@@ -17,7 +17,7 @@ Dinky 基于 Apache Flink 实现 Dlink ,增强 Flink 的应用与体验,探 ...@@ -17,7 +17,7 @@ Dinky 基于 Apache Flink 实现 Dlink ,增强 Flink 的应用与体验,探
## 特点 ## 特点
一个 `开箱即用``易扩展` `一站式` 实时计算平台,以 `Apache Flink` 为基础,连接 `OLAP``数据湖` 等众多框架,致力于 `流批一体``湖仓一体` 的建设与实践。 一个 `开箱即用``易扩展` ,以 `Apache Flink` 为基础,连接 `OLAP``数据湖` 等众多框架的 `一站式` 实时计算平台,致力于 `流批一体``湖仓一体` 的建设与实践。
其主要目标如下: 其主要目标如下:
......
...@@ -17,7 +17,7 @@ Dinky 基于 Apache Flink 实现 Dlink ,增强 Flink 的应用与体验,探 ...@@ -17,7 +17,7 @@ Dinky 基于 Apache Flink 实现 Dlink ,增强 Flink 的应用与体验,探
## 特点 ## 特点
一个 `开箱即用``易扩展` `一站式` 实时计算平台,以 `Apache Flink` 为基础,连接 `OLAP``数据湖` 等众多框架,致力于 `流批一体``湖仓一体` 的建设与实践。 一个 `开箱即用``易扩展` ,以 `Apache Flink` 为基础,连接 `OLAP``数据湖` 等众多框架的 `一站式` 实时计算平台,致力于 `流批一体``湖仓一体` 的建设与实践。
其主要目标如下: 其主要目标如下:
......
...@@ -17,7 +17,7 @@ Dinky 基于 Apache Flink 实现 Dlink ,增强 Flink 的应用与体验,探 ...@@ -17,7 +17,7 @@ Dinky 基于 Apache Flink 实现 Dlink ,增强 Flink 的应用与体验,探
## 特点 ## 特点
一个 `开箱即用``易扩展` `一站式` 实时计算平台,以 `Apache Flink` 为基础,连接 `OLAP``数据湖` 等众多框架,致力于 `流批一体``湖仓一体` 的建设与实践。 一个 `开箱即用``易扩展` ,以 `Apache Flink` 为基础,连接 `OLAP``数据湖` 等众多框架的 `一站式` 实时计算平台,致力于 `流批一体``湖仓一体` 的建设与实践。
其主要目标如下: 其主要目标如下:
......
![](https://gitee.com/DataLinkDC/dlink/raw/main/dlink-doc/images/main/dinky_principle.png) ![Dinky](http://www.aiwenmo.com/dinky/main/dinky.png)
...@@ -26,14 +26,33 @@ Dinky 通过调用 flink-yarn 模块进行二次开发。 ...@@ -26,14 +26,33 @@ Dinky 通过调用 flink-yarn 模块进行二次开发。
Dinky 也支持通过调用 JobManager 的 RestAPI 对任务进行管理等操作,系统配置可以控制开启和停用。 Dinky 也支持通过调用 JobManager 的 RestAPI 对任务进行管理等操作,系统配置可以控制开启和停用。
<big>**Local**</big>
Dinky 自身的 Flink 环境,通过 plugins 下的 Flink 依赖进行构建,主要用于语法校验和逻辑检查、生成 JobPlan 和 JobGraph、字段血缘分析等功能。
注意:目前请不要用该模式执行或提交流作业,将会无法关闭,需要重启进程才可。
<big>**Standalone**</big>
Dinky 通过已注册的 Flink Standalone 集群实例可以对远程集群进行 FlinkSQL 的提交、Catalog 的交互式管理以及对 SELECT 和 SHOW 等语句的执行结果预览。
<big>**Yarn-Session**</big> <big>**Yarn-Session**</big>
Dinky 通过已注册的 Flink Session 集群实例可以对 Standalone 和 Yarn-Session 两种集群进行 FlinkSQL 的提交、Catalog 的交互式管理以及对 SELECT 和 SHOW 等语句的执行结果预览。 Dinky 通过已注册的 Flink Yarn Session 集群实例可以对远程集群进行 FlinkSQL 的提交、Catalog 的交互式管理以及对 SELECT 和 SHOW 等语句的执行结果预览。
<big>**Yarn-Per-Job**</big> <big>**Yarn-Per-Job**</big>
Dinky 通过已注册的集群配置来获取对应的 YarnClient 实例,然后将本地解析生产的 JobGraph 与 Configuration 提交至 Yarn 来创建 Flink-Per-Job 应用。 Dinky 通过已注册的集群配置来获取对应的 YarnClient 实例,然后将 Local 模式解析生成的 JobGraph 与 Configuration 提交至 Yarn 来创建 Flink Per-Job 应用。
<big>**Yarn-Application**</big> <big>**Yarn-Application**</big>
Dinky 通过已注册的集群配置来获取对应的 YarnClient 实例。对于 User Jar,将 Jar 相关配置与 Configuration 提交至 Yarn 来创建 Flink-Application 应用;对于 Flink SQL,Dinky 则将作业 ID 及数据库连接配置作为 Main 入参和 dlink-app.jar 以及 Configuration 提交至 Yarn 来创建 Flink-Application 应用。 Dinky 通过已注册的集群配置来获取对应的 YarnClient 实例。对于 User Jar,将 Jar 相关配置与 Configuration 提交至 Yarn 来创建 Flink-Application 应用;对于 Flink SQL,Dinky 则将作业 ID 及数据库连接配置作为 Main 入参和 dlink-app.jar 以及 Configuration 提交至 Yarn 来创建 Flink-Application 应用。
\ No newline at end of file
<big>**Kubernetes-Session**</big>
Dinky 通过已注册的 Flink Kubernetes Session 集群实例可以对远程集群进行 FlinkSQL 的提交、Catalog 的交互式管理以及对 SELECT 和 SHOW 等语句的执行结果预览。
注意需要暴露 NodePort。
<big>**Kubernetes-Application**</big>
Dinky 通过已注册的集群配置来获取对应的 FlinkKubeClient 实例。对于 Flink SQL,Dinky 则将作业 ID 及数据库连接配置作为 Main 入参和定制的 dlink-app.jar 镜像以及 Configuration 提交至 Yarn 来创建 Flink-Application 应用。
注意需要自己打包 dlink-app 镜像,具体见文章。
注意:以下功能均为对应版本已实现的功能,实测可用。 注意:以下功能均为对应版本已实现的功能,实测可用。
| 应用 | 方向 | 功能 | 进展 | | 应用 | 方向 | 功能 | 进展 |
| :------: | :------------: | ------------------------------------------------------------ | :---: | | :------: | :------------: |-------------------------------------------|:-----:|
| 开发中心 | FlinkSQL | 支持 sql-client 所有语法 | 0.4.0 | | 开发中心 | FlinkSQL | 支持 sql-client 所有语法 | 0.4.0 |
| | | 支持 Flink 所有 Configuration | 0.4.0 | | | | 支持 Flink 所有 Configuration | 0.4.0 |
| | | 支持 Flink 所有 Connector | 0.4.0 | | | | 支持 Flink 所有 Connector | 0.4.0 |
| | | 支持 Flink 批流两种模式 | 0.6.0 | | | | 支持 Flink 批流两种模式 | 0.6.0 |
| | | 支持 SELECT、SHOW、DESC 等查询实时预览 | 0.4.0 | | | | 支持 SELECT、SHOW、DESC 等查询实时预览 | 0.4.0 |
| | | 支持 INSERT 语句集 | 0.4.0 | | | | 支持 INSERT 语句集 | 0.4.0 |
| | | 新增 SQL 片段语法(全局变量) | 0.4.0 | | | | 新增 SQL 片段语法(全局变量) | 0.4.0 |
| | | 新增 AGGTABLE 表值聚合语法及 UDATF 支持 | 0.4.0 | | | | 新增 AGGTABLE 表值聚合语法及 UDATF 支持 | 0.4.0 |
| | | 新增 CDCSOURCE 多源合并语法支持 | 0.6.0 | | | | 新增 CDCSOURCE 多源合并语法支持 | 0.6.0 |
| | | 新增 FlinkSQLEnv 执行环境复用 | 0.5.0 | | | | 新增 FlinkSQLEnv 执行环境复用 | 0.5.0 |
| | | 新增 Flink Catalog 交互查询 | 0.4.0 | | | | 新增 Flink Catalog 交互查询 | 0.4.0 |
| | | 新增 执行环境的共享与私有会话机制 | 0.4.0 | | | | 新增 执行环境的共享与私有会话机制 | 0.4.0 |
| | | 新增 多种方言的作业目录管理(FlinkSQL、SQL、Java) | 0.5.0 | | | | 新增 多种方言的作业目录管理(FlinkSQL、SQL、Java) | 0.5.0 |
| | | 新增 作业配置与执行配置管理 | 0.4.0 | | | | 新增 作业配置与执行配置管理 | 0.4.0 |
| | | 新增 作业生命周期管理 | 0.6.0 | | | | 新增 作业生命周期管理 | 0.6.0 |
| | | 新增 基于 Explain 的语法校验与逻辑解析 | 0.4.0 | | | | 新增 基于 Explain 的语法校验与逻辑解析 | 0.4.0 |
| | | 新增 JobPlan 图预览 | 0.5.0 | | | | 新增 JobPlan 图预览 | 0.5.0 |
| | | 新增 基于 StreamGraph 的字段级血缘分析 | 0.6.0 | | | | 新增 基于 StreamGraph 的字段级血缘分析 | 0.6.0 |
| | | 新增 基于上下文元数据自动提示与补全 | 0.4.0 | | | | 新增 基于上下文元数据自动提示与补全 | 0.4.0 |
| | | 新增 自定义规则的自动提示与补全 | 0.4.0 | | | | 新增 自定义规则的自动提示与补全 | 0.4.0 |
| | | 新增 关键字高亮与代码缩略图 | 0.4.0 | | | | 新增 关键字高亮与代码缩略图 | 0.4.0 |
| | | 新增 选中片段执行 | 0.4.0 | | | | 新增 选中片段执行 | 0.4.0 |
| | | 新增 布局拖拽 | 0.4.0 | | | | 新增 布局拖拽 | 0.4.0 |
| | | 新增 SQL导出 | 0.5.0 | | | | 新增 SQL导出 | 0.5.0 |
| | | 新增 快捷键保存、校验、美化 | 0.5.0 | | | | 新增 快捷键保存、校验、美化 | 0.5.0 |
| | | 支持 local 模式下 FlinkSQL 提交 | 0.4.0 | | | | 支持 local 模式下 FlinkSQL 提交 | 0.4.0 |
| | | 支持 standalone 模式下 FlinkSQL 提交 | 0.4.0 | | | | 支持 standalone 模式下 FlinkSQL 提交 | 0.4.0 |
| | | 支持 yarn session 模式下 FlinkSQL 提交 | 0.4.0 | | | | 支持 yarn session 模式下 FlinkSQL 提交 | 0.4.0 |
| | | 支持 yarn per-job 模式下 FlinkSQL 提交 | 0.4.0 | | | | 支持 yarn per-job 模式下 FlinkSQL 提交 | 0.4.0 |
| | | 支持 yarn application 模式下 FlinkSQL 提交 | 0.4.0 | | | | 支持 yarn application 模式下 FlinkSQL 提交 | 0.4.0 |
| | | 支持 kubernetes session 模式下 FlinkSQL 提交 | 0.5.0 | | | | 支持 kubernetes session 模式下 FlinkSQL 提交 | 0.5.0 |
| | | 支持 kubernetes application 模式下 FlinkSQL 提交 | 0.5.0 | | | | 支持 kubernetes application 模式下 FlinkSQL 提交 | 0.5.0 |
| | | 支持 UDF Java 方言Local模式在线编写、调试、动态加载 | 0.5.0 | | | | 支持 UDF Java 方言Local模式在线编写、调试、动态加载 | 0.5.0 |
| | Flink 作业 | 支持 yarn application 模式下 Jar 提交 | 0.4.0 | | | Flink 作业 | 支持 yarn application 模式下 Jar 提交 | 0.4.0 |
| | | 支持 k8s application 模式下 Jar 提交 | 0.5.0 | | | | 支持 k8s application 模式下 Jar 提交 | 0.5.0 |
| | | 支持 作业 Cancel | 0.4.0 | | | | 支持 作业 Cancel | 0.4.0 |
| | | 支持 作业 SavePoint 的 Cancel、Stop、Trigger | 0.4.0 | | | | 支持 作业 SavePoint 的 Cancel、Stop、Trigger | 0.4.0 |
| | | 新增 作业自动从 SavePoint 恢复机制(包含最近、最早、指定一次) | 0.4.0 | | | | 新增 作业自动从 SavePoint 恢复机制(包含最近、最早、指定一次) | 0.4.0 |
| | Flink 集群 | 支持 查看已注册集群的作业列表与运维 | 0.4.0 | | | Flink 集群 | 支持 查看已注册集群的作业列表与运维 | 0.4.0 |
| | | 新增 自动注册 Yarn 创建的集群 | 0.4.0 | | | | 新增 自动注册 Yarn 创建的集群 | 0.4.0 |
| | Flink 版本 | 支持 1.11.0+ | 0.4.0 | | | Flink 版本 | 支持 1.11.0+ | 0.4.0 |
| | | 支持 1.12.0+ | 0.4.0 | | | | 支持 1.12.0+ | 0.4.0 |
| | | 支持 1.13.0+ | 0.4.0 | | | | 支持 1.13.0+ | 0.4.0 |
| | | 支持 1.14.0+ | 0.4.0 | | | | 支持 1.14.0+ | 0.4.0 |
| | SQL | 新增 外部数据源的 SQL 校验 | 0.5.0 | | | SQL | 新增 外部数据源的 SQL 校验 | 0.5.0 |
| | | 新增 外部数据源的 SQL 执行与预览 | 0.5.0 | | | | 新增 外部数据源的 SQL 执行与预览 | 0.5.0 |
| | BI | 新增 折线图的渲染 | 0.5.0 | | | BI | 新增 折线图的渲染 | 0.5.0 |
| | | 新增 条形图图的渲染 | 0.5.0 | | | | 新增 条形图图的渲染 | 0.5.0 |
| | | 新增 饼图的渲染 | 0.5.0 | | | | 新增 饼图的渲染 | 0.5.0 |
| | 元数据 | 新增 查询外部数据源的元数据信息 | 0.4.0 | | | 元数据 | 新增 查询外部数据源的元数据信息 | 0.4.0 |
| | | 新增 FlinkSQL 和 SQL 的自动生成 | 0.6.0 | | | | 新增 FlinkSQL 和 SQL 的自动生成 | 0.6.0 |
| | | 新增 自动将连接信息注入片段机制 | 0.6.0 | | | | 新增 自动将连接信息注入片段机制 | 0.6.0 |
| | 归档 | 新增 执行与提交历史 | 0.4.0 | | | 归档 | 新增 执行与提交历史 | 0.4.0 |
| 运维中心 | 主页 | 新增 任务实例列表 | 0.6.0 | | 运维中心 | 主页 | 新增 任务实例列表 | 0.6.0 |
| | 作业监控 | 新增 作业总览 | 0.6.0 | | | 作业监控 | 新增 作业总览 | 0.6.0 |
| | | 新增 实时监控 Flink Job | 0.6.0 | | | | 新增 实时监控 Flink Job | 0.6.0 |
| | | 新增 作业实例与历史切换 | 0.6.0 | | | | 新增 作业实例与历史切换 | 0.6.0 |
| | | 新增 自动告警 | 0.6.0 | | | | 新增 自动告警 | 0.6.0 |
| | | 新增 FlinkWebUI 跳转 | 0.6.0 | | | | 新增 FlinkWebUI 跳转 | 0.6.0 |
| | | 新增 智能重启(重新上线) | 0.6.0 | | | | 新增 智能重启(重新上线) | 0.6.0 |
| | | 新增 智能停止(下线) | 0.6.0 | | | | 新增 智能停止(下线) | 0.6.0 |
| | | 新增 SavePoint 多种操作 | 0.6.0 | | | | 新增 SavePoint 多种操作 | 0.6.0 |
| | | 新增 报警推送 | 0.6.0 | | | | 新增 报警推送 | 0.6.0 |
| | | 新增 配置信息 | 0.6.0 | | | | 新增 配置信息 | 0.6.0 |
| | | 新增 集群信息 | dev | | | | 新增 集群信息 | dev |
| | | 新增 作业快照 | dev | | | | 新增 作业快照 | dev |
| | | 新增 异常信息 | 0.6.0 | | | | 新增 异常信息 | 0.6.0 |
| | | 新增 作业日志 | dev | | | | 新增 作业日志 | dev |
| | | 新增 自动调优 | dev | | | | 新增 自动调优 | dev |
| | | 新增 FlinkSQL | 0.6.0 | | | | 新增 FlinkSQL | 0.6.0 |
| | | 新增 数据地图 | 0.6.0 | | | | 新增 数据地图 | 0.6.0 |
| | | 新增 即席查询 | dev | | | | 新增 即席查询 | dev |
| | | 新增 历史版本 | dev | | | | 新增 历史版本 | dev |
| | | 新增 告警记录 | 0.6.0 | | | | 新增 告警记录 | 0.6.0 |
| 注册中心 | Flink 集群实例 | 新增 外部 Flink 集群实例注册 | 0.4.0 | | 注册中心 | Flink 集群实例 | 新增 外部 Flink 集群实例注册 | 0.4.0 |
| | | 新增 外部 Flink 集群实例心态检测与版本获取 | 0.4.0 | | | | 新增 外部 Flink 集群实例心态检测与版本获取 | 0.4.0 |
| | | 新增 外部 Flink 集群手动一键回收 | 0.4.0 | | | | 新增 外部 Flink 集群手动一键回收 | 0.4.0 |
| | Flink 集群配置 | 新增 Flink On Yarn 集群配置注册及测试 | 0.4.0 | | | Flink 集群配置 | 新增 Flink On Yarn 集群配置注册及测试 | 0.4.0 |
| | User Jar | 新增 外部 User Jar 注册 | 0.4.0 | | | User Jar | 新增 外部 User Jar 注册 | 0.4.0 |
| | 数据源 | 新增 Mysql 数据源注册及测试 | 0.4.0 | | | 数据源 | 新增 Mysql 数据源注册及测试 | 0.4.0 |
| | | 新增 Oracle 数据源注册及测试 | 0.4.0 | | | | 新增 Oracle 数据源注册及测试 | 0.4.0 |
| | | 新增 PostgreSql 数据源注册及测试 | 0.4.0 | | | | 新增 PostgreSql 数据源注册及测试 | 0.4.0 |
| | | 新增 ClickHouse 数据源注册及测试 | 0.4.0 | | | | 新增 ClickHouse 数据源注册及测试 | 0.4.0 |
| | | 新增 Doris 数据源注册及测试 | 0.6.0 | | | | 新增 Doris 数据源注册及测试 | 0.6.0 |
| | | 新增 Phoenix 数据源注册及测试 | 0.6.0 | | | | 新增 Phoenix 数据源注册及测试 | 0.6.0 |
| | | 新增 SqlServer 数据源注册及测试 | 0.6.0 | | | | 新增 SqlServer 数据源注册及测试 | 0.6.0 |
| | | 新增 Hive 数据源注册及测试 | 0.6.0 | | | | 新增 Hive 数据源注册及测试 | 0.6.0 |
| | 报警实例管理 | 新增 钉钉报警 | 0.6.0 | | | 报警实例管理 | 新增 钉钉报警 | 0.6.0 |
| | | 新增 微信企业号报警 | 0.6.0 | | | | 新增 微信企业号报警 | 0.6.0 |
| | 报警组管理 | 新增 报警组管理 | 0.6.0 | | | | 新增 邮箱报警 | 0.6.1 |
| 系统设置 | 用户管理 | 新增 用户基本管理 | 0.5.0 | | | | 新增 飞书报警 | 0.6.1 |
| | | 新增 修改密码 | 0.6.0 | | | 报警组管理 | 新增 报警组管理 | 0.6.0 |
| | Flink 设置 | 新增 Application 的通用模板 Jar 配置 | 0.4.0 | | 系统设置 | 用户管理 | 新增 用户基本管理 | 0.5.0 |
| | | 新增 是否使用 RestAPI 配置 | 0.4.0 | | | | 新增 修改密码 | 0.6.0 |
| | | 新增 SQL 语句分隔符配置 | 0.4.0 | | | Flink 设置 | 新增 Application 的通用模板 Jar 配置 | 0.4.0 |
| OpenApi | 调度 | 新增 submitTask 调度接口 | 0.5.0 | | | | 新增 是否使用 RestAPI 配置 | 0.4.0 |
| | FlinkSQL | 新增 executeSql 提交接口 | 0.5.0 | | | | 新增 SQL 语句分隔符配置 | 0.4.0 |
| | | 新增 explainSql 验证接口 | 0.5.0 | | OpenApi | 调度 | 新增 submitTask 调度接口 | 0.5.0 |
| | | 新增 getJobPlan 计划接口 | 0.5.0 | | | FlinkSQL | 新增 executeSql 提交接口 | 0.5.0 |
| | | 新增 getStreamGraph 计划接口 | 0.5.0 | | | | 新增 explainSql 验证接口 | 0.5.0 |
| | | 新增 getJobData 数据接口 | 0.5.0 | | | | 新增 getJobPlan 计划接口 | 0.5.0 |
| | Flink | 新增 executeJar 提交接口 | 0.5.0 | | | | 新增 getStreamGraph 计划接口 | 0.5.0 |
| | | 新增 cancel 停止接口 | 0.5.0 | | | | 新增 getJobData 数据接口 | 0.5.0 |
| | | 新增 savepoint 触发接口 | 0.5.0 | | | Flink | 新增 executeJar 提交接口 | 0.5.0 |
| 关于 | 关于 Dlink | 版本更新记录 | 0.4.0 | | | | 新增 cancel 停止接口 | 0.5.0 |
| | | 新增 savepoint 触发接口 | 0.5.0 |
| | | 新增 savepointTask 触发接口 | 0.6.1 |
| 关于 | 关于 Dlink | 版本更新记录 | 0.4.0 |
## Dinky介绍 ## 介绍
实时即未来,Dlink 为 Apache Flink 而生,让 Flink SQL 纵享丝滑,并致力于实时计算平台建设。 实时即未来,Dlink 为 Apache Flink 而生,让 Flink SQL 纵享丝滑,并致力于实时计算平台建设。
...@@ -6,11 +6,32 @@ Dinky 基于 Apache Flink 实现 Dlink ,增强 Flink 的应用与体验,探 ...@@ -6,11 +6,32 @@ Dinky 基于 Apache Flink 实现 Dlink ,增强 Flink 的应用与体验,探
最后,Dinky 的发展皆归功于 Apache Flink 等其他优秀的开源项目的指导与成果。 最后,Dinky 的发展皆归功于 Apache Flink 等其他优秀的开源项目的指导与成果。
## Dinky由来 ## 由来
Dinky(原 Dlink): Dinky(原 Dlink):
1.Dinky 英译为 “ 小巧而精致的 ” ,最直观的表明了它的特征:轻量级但又具备复杂的大数据开发能力。 1.Dinky 英译为 “ 小巧而精致的 ” ,最直观的表明了它的特征:轻量级但又具备复杂的大数据开发能力。
2.为 “ Data Integrate No Knotty ” 的首字母组合,英译 “ 数据整合不难 ”,寓意 “ 易于建设批流一体平台及应用 ”。 2.为 “ Data Integrate No Knotty ” 的首字母组合,英译 “ 数据整合不难 ”,寓意 “ 易于建设批流一体平台及应用 ”。
3.从 Dlink 改名为 Dinky 过渡平滑,更加形象的阐明了开源项目的目标,始终指引参与者们 “不忘初心,方得始终 ”。 3.从 Dlink 改名为 Dinky 过渡平滑,更加形象的阐明了开源项目的目标,始终指引参与者们 “不忘初心,方得始终 ”。
\ No newline at end of file
## 特点
一个 `开箱即用``易扩展` ,以 `Apache Flink` 为基础,连接 `OLAP``数据湖` 等众多框架的 `一站式` 实时计算平台,致力于 `流批一体``湖仓一体` 的建设与实践。
其主要目标如下:
- 可视化交互式 FlinkSQL 和 SQL 的数据开发平台:自动提示补全、语法高亮、调试执行、语法校验、语句美化、全局变量等
- 支持全面的多版本的 FlinkSQL 作业提交方式:Local、Standalone、Yarn Session、Yarn Per-Job、Yarn Application、Kubernetes Session、Kubernetes Application
- 支持 Apache Flink 所有的 Connector、UDF、CDC等
- 支持 FlinkSQL 语法增强:兼容 Apache Flink SQL、表值聚合函数、全局变量、CDC多源合并、执行环境、语句合并、共享会话等
- 支持易扩展的 SQL 作业提交方式:ClickHouse、Doris、Hive、Mysql、Oracle、Phoenix、PostgreSql、SqlServer 等
- 支持实时调试预览 Table 和 ChangeLog 数据及图形展示
- 支持语法逻辑检查、作业执行计划、字段级血缘分析等
- 支持 Flink 元数据、数据源元数据查询及管理
- 支持实时任务运维:作业上线下线、作业信息、集群信息、作业快照、异常信息、作业日志、数据地图、即席查询、历史版本、报警记录等
- 支持作为多版本 FlinkSQL Server 的能力以及 OpenApi
- 支持易扩展的实时作业报警及报警组:钉钉、微信企业号等
- 支持完全托管的 SavePoint 启动机制:最近一次、最早一次、指定一次等
- 支持多种资源管理:集群实例、集群配置、Jar、数据源、报警组、报警实例、文档、用户、系统配置等
- 更多隐藏功能等待小伙伴们探索
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment