功能
注意:以下功能均为对应版本已实现的功能,实测可用。
应用 | 方向 | 功能 | 进展 |
---|---|---|---|
开发中心 | FlinkSQL | 支持 sql-client 语法 | 0.4.0 |
支持 Flink 所有 Configuration | 0.4.0 | ||
支持 Flink 所有 Connector | 0.4.0 | ||
支持 Flink 批流两种模式 | 0.6.0 | ||
支持 SELECT、SHOW、DESC 等查询实时预览 | 0.4.0 | ||
支持 INSERT 语句集 | 0.4.0 | ||
新增 SQL 全局变量 | 0.4.0 | ||
新增 AGGTABLE 表值聚合语法及 UDATF 支持 | 0.4.0 | ||
新增 CDCSOURCE 整库同步语法 | 0.6.0 | ||
新增 FlinkSQLEnv 执行环境 | 0.5.0 | ||
新增 Flink Catalog 交互查询及持久化 | 0.4.0 | ||
新增 执行环境的共享与私有会话 | 0.4.0 | ||
新增 多种方言的作业目录管理(FlinkSQL、SQL) | 0.5.0 | ||
新增 作业配置与执行配置管理 | 0.4.0 | ||
新增 作业生命周期管理 | 0.6.0 | ||
新增 FlinkSQL 作业版本对比 | 0.6.6 | ||
新增 基于 Explain 的语法校验与逻辑解析 | 0.4.0 | ||
新增 JobPlan 图预览 | 0.5.0 | ||
新增 基于 StreamGraph 的字段级血缘分析 | 0.6.0 | ||
新增 基于上下文元数据自动提示与补全 | 0.4.0 | ||
新增 自定义规则的自动提示与补全 | 0.4.0 | ||
新增 关键字高亮与代码缩略图 | 0.4.0 | ||
新增 选中片段执行 | 0.4.0 | ||
新增 布局拖拽 | 0.4.0 | ||
新增 SQL导出 | 0.5.0 | ||
新增 作业批量导出导入 | 0.6.6 | ||
新增 作业复制 | 0.6.5 | ||
新增 快捷键保存、校验、美化 | 0.5.0 | ||
支持 local 模式下 FlinkSQL 提交 | 0.4.0 | ||
支持 standalone 模式下 FlinkSQL 提交 | 0.4.0 | ||
支持 yarn session 模式下 FlinkSQL 提交 | 0.4.0 | ||
支持 yarn per-job 模式下 FlinkSQL 提交 | 0.4.0 | ||
支持 yarn application 模式下 FlinkSQL 提交 | 0.4.0 | ||
支持 kubernetes session 模式下 FlinkSQL 提交 | 0.5.0 | ||
支持 kubernetes application 模式下 FlinkSQL 提交 | 0.5.0 | ||
支持 UDF Java 方言Local模式在线编写、调试、动态加载 | 0.5.0 | ||
Flink 作业 | 支持 yarn application 模式下 Jar 提交 | 0.4.0 | |
支持 k8s application 模式下 Jar 提交 | 0.5.0 | ||
支持 作业 Cancel | 0.4.0 | ||
支持 作业 SavePoint 的 Cancel、Stop、Trigger | 0.4.0 | ||
新增 作业自动从 SavePoint/CheckPoint 恢复机制(包含最近、最早、指定一次) | 0.4.0 | ||
新增 作业手动从指定 SavePoint/CheckPoint 恢复 | 0.6.6 | ||
Flink 集群 | 支持 查看已注册集群的作业列表与运维 | 0.4.0 | |
新增 自动注册 Yarn/K8S 创建的集群 | 0.4.0 | ||
新增 FlinkWebUI 跳转 | 0.6.2 | ||
Flink 版本 | 支持 1.11.0+ | 0.4.0 | |
支持 1.12.0+ | 0.4.0 | ||
支持 1.13.0+ | 0.4.0 | ||
支持 1.14.0+ | 0.4.0 | ||
支持 1.14.0+ | 0.4.0 | ||
支持 1.15.0+ | 0.6.3 | ||
SQL | 新增 外部数据源的 SQL 校验 | 0.5.0 | |
新增 外部数据源的 SQL 执行与预览 | 0.5.0 | ||
新增 外部数据源的 SQL 字段血缘分析 | 0.6.4 | ||
BI | 新增 折线图的渲染 | 0.5.0 | |
新增 条形图图的渲染 | 0.5.0 | ||
新增 饼图的渲染 | 0.5.0 | ||
元数据 | 新增 查询外部数据源的元数据信息 | 0.4.0 | |
新增 FlinkSQL 和 SQL 的自动生成 | 0.6.0 | ||
新增 自动将连接信息注入片段机制 | 0.6.0 | ||
归档 | 新增 执行与提交历史 | 0.4.0 | |
新增 发布版本管理与回滚 | 0.6.6 | ||
运维中心 | 主页 | 新增 任务实例列表 | 0.6.0 |
作业监控 | 新增 作业总览 | 0.6.0 | |
新增 实时监控 Flink Job | 0.6.0 | ||
新增 作业实例与历史切换 | 0.6.0 | ||
新增 自动告警 | 0.6.0 | ||
新增 FlinkWebUI 跳转 | 0.6.0 | ||
新增 智能重启(重新上线) | 0.6.0 | ||
新增 智能停止(下线) | 0.6.0 | ||
新增 SavePoint 多种操作 | 0.6.0 | ||
新增 报警推送 | 0.6.0 | ||
新增 配置信息 | 0.6.0 | ||
新增 集群信息 | 0.6.5 | ||
新增 作业快照 | 0.6.5 | ||
新增 异常信息 | 0.6.0 | ||
新增 作业日志 | dev | ||
新增 自动调优 | dev | ||
新增 FlinkSQL | 0.6.0 | ||
新增 数据地图 | 0.6.0 | ||
新增 即席查询 | dev | ||
新增 历史版本 | 0.6.6 | ||
新增 告警记录 | 0.6.0 | ||
新增 一键上下线功能 | 0.6.6 | ||
注册中心 | Flink 集群实例 | 新增 外部 Flink 集群实例注册 | 0.4.0 |
新增 外部 Flink 集群实例心态检测与版本获取 | 0.4.0 | ||
新增 外部 Flink 集群手动一键回收 | 0.4.0 | ||
Flink 集群配置 | 新增 Flink On Yarn/K8S 集群配置注册及测试 | 0.4.0 | |
User Jar | 新增 外部 User Jar 注册 | 0.4.0 | |
数据源 | 新增 Mysql 数据源注册及测试 | 0.4.0 | |
新增 Oracle 数据源注册及测试 | 0.4.0 | ||
新增 PostgreSql 数据源注册及测试 | 0.4.0 | ||
新增 ClickHouse 数据源注册及测试 | 0.4.0 | ||
新增 Doris 数据源注册及测试 | 0.6.0 | ||
新增 Phoenix 数据源注册及测试 | 0.6.0 | ||
新增 SqlServer 数据源注册及测试 | 0.6.0 | ||
新增 Hive 数据源注册及测试 | 0.6.0 | ||
报警实例管理 | 新增 钉钉报警 | 0.6.0 | |
新增 微信企业号报警 | 0.6.0 | ||
新增 邮箱报警 | 0.6.1 | ||
新增 飞书报警 | 0.6.1 | ||
报警组管理 | 新增 报警组管理 | 0.6.0 | |
系统设置 | 用户管理 | 新增 用户基本管理 | 0.5.0 |
新增 修改密码 | 0.6.0 | ||
Flink 设置 | 新增 Application 的通用模板 Jar 配置 | 0.4.0 | |
新增 是否使用 RestAPI 配置 | 0.4.0 | ||
新增 SQL 语句分隔符配置 | 0.4.0 | ||
OpenApi | 调度 | 新增 submitTask 调度接口 | 0.5.0 |
FlinkSQL | 新增 executeSql 提交接口 | 0.5.0 | |
新增 explainSql 验证接口 | 0.5.0 | ||
新增 getJobPlan 计划接口 | 0.5.0 | ||
新增 getStreamGraph 计划接口 | 0.5.0 | ||
新增 getJobData 数据接口 | 0.5.0 | ||
Flink | 新增 executeJar 提交接口 | 0.5.0 | |
新增 cancel 停止接口 | 0.5.0 | ||
新增 savepoint 触发接口 | 0.5.0 | ||
新增 savepointTask 触发接口 | 0.6.1 | ||
新增 restartTask 重启接口 | 0.6.5 | ||
新增 selectSavePointRestartTask 重启接口 | 0.6.5 | ||
新增 onLineTask 上线接口 | 0.6.5 | ||
新增 offLineTask 下线接口 | 0.6.5 | ||
新增 reOnLineTask 重新上线接口 | 0.6.5 | ||
新增 selectSavePointReOnLineTask 重新上线接口 | 0.6.5 | ||
新增 getJobInstance 获取实例接口 | 0.6.5 | ||
新增 getJobInstanceByTaskId 获取实例接口 | 0.6.5 | ||
关于 | 关于 Dlink | 版本更新记录 | 0.4.0 |