Unverified Commit 1df3fa29 authored by aiwenmo's avatar aiwenmo Committed by GitHub

[Document-1060][doc] Update website (#1061)

Co-authored-by: 's avatarwenmo <32723967+wenmo@users.noreply.github.com>
parent 4a76b825
......@@ -107,11 +107,14 @@ public class StudioServiceImpl implements StudioService {
private FragmentVariableService fragmentVariableService;
private void addFlinkSQLEnv(AbstractStatementDTO statementDTO) {
// initialize global variables
statementDTO.setVariables(fragmentVariableService.listEnabledVariables());
// initialize database variables
String flinkWithSql = dataBaseService.getEnabledFlinkWithSql();
if (statementDTO.isFragment() && Asserts.isNotNullString(flinkWithSql)) {
statementDTO.setStatement(flinkWithSql + "\r\n" + statementDTO.getStatement());
}
// initialize flinksql environment, such as flink catalog
if (Asserts.isNotNull(statementDTO.getEnvId()) && !statementDTO.getEnvId().equals(0)) {
Task task = taskService.getTaskInfoById(statementDTO.getEnvId());
if (Asserts.isNotNull(task) && Asserts.isNotNullString(task.getStatement())) {
......@@ -141,7 +144,7 @@ public class StudioServiceImpl implements StudioService {
addFlinkSQLEnv(studioExecuteDTO);
JobConfig config = studioExecuteDTO.getJobConfig();
buildSession(config);
// To initialize java udf, but it has a bug in the product environment now.
// To initialize java udf, but it only support local mode.
initUDF(config, studioExecuteDTO.getStatement());
JobManager jobManager = JobManager.build(config);
JobResult jobResult = jobManager.executeSql(studioExecuteDTO.getStatement());
......
......@@ -26,10 +26,6 @@ package com.dlink.constant;
* @since 2021/5/28 9:35
**/
public interface CommonConstant {
/**
* 项目版本号(banner使用)
*/
String PROJECT_VERSION = "0.6.7-SNAPSHOT";
/**
* 实例健康
*/
......
......@@ -12,6 +12,7 @@ Dinky 基于 Apache Flink 进行扩展 ,增强 Flink 的应用与体验,探
最后,Dinky 的发展皆归功于 Apache Flink 等其他优秀的开源项目的指导与成果。
## 由来
Dinky(原 Dlink):
1.Dinky 英译为 “ 小巧而精致的 ” ,最直观的表明了它的特征:轻量级但又具备复杂的大数据开发能力。
......@@ -26,22 +27,17 @@ Dinky(原 Dlink):
其主要目标如下:
- 沉浸式 FlinkSQL 和 SQL 的数据开发平台:
自动提示补全、语法高亮、语句美化、语法校验、调试执行、执行计划、MetaStore、血缘分析、版本对比等
- 支持多版本的 FlinkSQL 作业各种提交方式:
Local、Standalone、Yarn/Kubernetes Session、Yarn Per-Job、Yarn/Kubernetes Application
- 支持 Apache Flink 所有原生及扩展的 Connector、UDF、CDC 等
- 支持 FlinkSQL 语法增强:
兼容 Apache Flink SQL、表值聚合函数、全局变量、执行环境、语句合并、整库同步、共享会话等
- 支持易扩展的 SQL 作业:
ClickHouse、Doris、Hive、Mysql、Oracle、Phoenix、PostgreSql、SqlServer 等
- 支持 FlinkCDC(Source 合并)整库实时入仓入湖
- 支持实时调试预览 Table 和 ChangeLog 数据及 Charts 图形展示
- 支持 Flink 元数据、数据源元数据查询及管理
- 支持实时任务运维:
上线下线、作业信息、集群信息、作业快照、异常信息、数据地图、数据探查、历史版本、报警记录等
- 沉浸式 FlinkSQL 数据开发:自动提示补全、语法高亮、语句美化、在线调试、语法校验、执行计划、MetaStore、血缘分析、版本对比等
- 支持 FlinkSQL 多版本开发及多种执行模式:Local、Standalone、Yarn/Kubernetes Session、Yarn Per-Job、Yarn/Kubernetes Application
- 支持 Apache Flink 生态:Connector、FlinkCDC、Table Store 等
- 支持 FlinkSQL 语法增强:表值聚合函数、全局变量、执行环境、语句合并、整库同步、共享会话等
- 支持 FlinkCDC 整库实时入仓入湖、多库输出、自动建表
- 支持 SQL 作业开发:ClickHouse、Doris、Hive、Mysql、Oracle、Phoenix、PostgreSql、SqlServer、StarRocks 等
- 支持实时在线调试预览 Table、 ChangeLog、统计图和 UDF
- 支持 Flink Catalog、数据源元数据在线查询及管理
- 支持实时任务运维:上线下线、作业信息、集群信息、作业快照、异常信息、数据地图、数据探查、历史版本、报警记录等
- 支持作为多版本 FlinkSQL Server 以及 OpenApi 的能力
- 支持易扩展的实时作业报警及报警组:钉钉、微信企业号、飞书、邮箱等
- 支持完全托管的 SavePoint/CheckPoint 启动及触发机制:最近一次、最早一次、指定一次等
- 支持实时作业报警及报警组:钉钉、微信企业号、飞书、邮箱等
- 支持自动托管的 SavePoint/CheckPoint 恢复及触发机制:最近一次、最早一次、指定一次等
- 支持多种资源管理:集群实例、集群配置、Jar、数据源、报警组、报警实例、文档、用户、系统配置等
- 更多隐藏功能待小伙伴们探索
- 更多隐藏功能待小伙伴们探索
---
sidebar_position: 90
title: 0.6.7 release
---
| 版本 | 二进制程序 | Source |
|-------|-----------------------------------------------------------------------------------------------------------------------|---------------------------------------------------------------------------------------|
| 0.6.7 | [dlink-release-0.6.7.tar.gz](https://github.com/DataLinkDC/dlink/releases/download/v0.6.7/dlink-release-0.6.7.tar.gz) | [Source code (zip)](https://github.com/DataLinkDC/dlink/archive/refs/tags/v0.6.7.zip) |
## Dinky发行说明
Dinky 0.6.7 是一个修复的版本。
:::warning 注意
该版本多租户功能暂未开放
此版本有表结构变更 <br/>
需要按需执行 **sql/dlink_history.sql** 文件的增量 DDL
:::
### 新功能
- 添加多租户的实现
- 一键上线和下线作业
- 添加全局变量管理
- 添加命名空间与密码的表单
- 登录时选择多租户
- 多租户前端业务管理实现
- 添加 github 工作流来检查代码风格、测试类和打包
- 添加 druid 连接池来解决jdbc多连接问题
- 新增用户授权角色的功能
- 修改 Flink 默认版本为 1.14
- 新增全局变量管理实现
- 新增 SqlServer 整库同步
- 新增全局变量在 Flinksql 中生效
- 新增字段血缘分析从 Flink 逻辑计划获取
- 新增 postgresql 整库同步
- 修改 checkstyle 为必须的工作
- 新增 swagger api 文档
- cdcsource 增加多目标库同步功能
- 新增文件上传
- Jar 和集群配置管理新增文件上传
- 新增 StarRocks 数据源
- 新增任务监控失败重复的容错时间
- 新增数据开发任务信息日志详情按钮
### 修复
- 修改任务监控代码重复判断的问题
- 修复邮件报警参数问题
- 修复获取作业实例信息可能获取到错误的结果问题
- 修复 doris 连接器批量写入时发生异常导致写入失败
- 修复 SQLSinkBuilder.buildRow 的错误
- 修复 Flink1.14 执行缺失依赖的问题
- 修复 savepoint 接口获取前端集群表单的 taskId 为空的问题
- 修复 yarn per-job 无法自动释放资源的问题
- 修复多租户新增角色和删除角色的问题
- 修复 dlink-conector-pulsar-1.14 找不到 SubscriptionType 的报错
- 修复 flink1.14 savepoint 时的 jackjson 问题
- 修复元数据字段类型转换的问题
- 修复整库同步 KafkaSinkBuilder 未序列化导致报错
- 修复注册中心文档管理的查询条件错误
- 修复 yarn perjob/application 和 k8s application 集群配置未生效
- 修复 k8s application 模式提交失败,优化增加获取JobId等待时间
- 修复日志 banner 的错误
- 修复 UDF 和 UDTAF 在 Flink 1.14 的错误
- 修复 yarn-application 任务分隔符错误
- 修复重命名作业后保存作业失败
- 修复提交历史的第二次弹框时无内容
### 优化
- 优化前端和文档
- 优化作业被删除后作业版本未被删除
- 优化作业树在导入作业后溢出的问题
- 优化数据开发的进程列表
- 优化整库同步分流逻辑
- 优化git提交忽略的文件类型
- 优化中文和英文 Readme
- 移除一些接口的敏感信息
- 优化多租户
- 添加 Maven Wrapper
- 优化整库同步的时区问题
- 优化sql默认分隔符统一为 ;\n
- 优化代码风格的错误
- 添加 .DS_Store 到 git 的忽略文件类型
- 优化多租户和表单渲染
- 优化多租户角色穿梭框和前端回显
- 优化用户关联角色渲染
- 优化 dlink-admin 的代码风格
- 优化 dlink-alert 的代码风格
- 优化 dlink-common 的代码风格
- 优化 dlink-catalog 的代码风格
- 优化 dlink-client 的代码风格
- 优化 dlink-app 的代码风格
- 优化数据源连接池和链接创建
- 优化 dlink-connectors 的代码风格
- 优化 dlink-core 的代码风格
- 优化 dlink-daemon 的代码风格
- 优化 dlink-executor 的代码风格
- 优化 dlink-function 和 dlink-gateway 的代码风格
- 优化 dlink-metadata 的代码风格
- 添加协议头到 pom 文件
- 优化项目打包和启动文件
- dlink-client-hadoop 打包增加 ServicesResourceTransformer
- 优化配置文件和静态资源目录打包
- 配置全局 checkstyle 验证
- 添加 sqlserver 的 date 类型转换
- 优化PG数据库 schema_name 查询 sql
- Doris 支持更多语法
- 优化整库同步 DorisSink
- 优化前端的展示与提示
- 优化数据开发作业目录默认折叠
- 优化 DorisSink 和升级 Flink 1.15.2
- 升级 Flink 1.15 版本为 1.15.2
- 优化 SqlServer 字段类型查询
### 文档
- 合并官网文档仓库源码至主仓库的 docs 目录下
- 添加 Flink 1.15 文档
- 整库同步文档修复
- 添加导入导出作业的文档
- 优化多个文档
- 更新主页和基础信息的文档
- 新增 flink 扩展 redis 的实践分享
- 优化部署文档
......@@ -5,6 +5,14 @@ title: 下载 Dinky
使用以下链接,下载并查看发行说明
## 0.6.7 release
- **发行时间:** 2022-09-06
- **[下载及发行说明](./dinky-0.6.7)**
---
## 0.6.6 release
- **发行时间:** 2022-07-23
......
......@@ -27,8 +27,8 @@ const FeatureList = [
Svg: require('@site/static/img/immersive.svg').default,
description: (
<>
自动提示与补全、高亮美化、语法校验、调试预览结果、元数据管理、全局变量
字段级血缘分析等
提供专业的 DataStudio 功能,支持全屏开发、自动提示与补全、语法高亮、语句美化、语法校验
调试预览结果、全局变量、MetaStore、字段级血缘分析、元数据查询、FlinkSQL 生成等功能
</>
),
},
......@@ -37,7 +37,8 @@ const FeatureList = [
Svg: require('@site/static/img/ease_of_use.svg').default,
description: (
<>
Apache Flink 多种执行模无感知切换,支持 Flink 多版本,自动化托管实时任务及恢复点,自定义各种配置
Flink 多种执行模式无感知切换,支持 Flink 多版本切换,自动化托管实时任务、恢复点、报警等,
自定义各种配置,持久化管理的 Flink Catalog
</>
),
},
......@@ -46,7 +47,8 @@ const FeatureList = [
Svg: require('@site/static/img/easy_of_deploy.svg').default,
description: (
<>
增强 FlinkSQL 语法及机制,如表值聚合函数、全局变量、CDC整库同步、执行环境、语句合并、共享会话等
兼容且增强官方 FlinkSQL 语法,如 SQL 表值聚合函数、全局变量、CDC 整库同步、执行环境、
语句合并、共享会话等
</>
),
},
......@@ -55,7 +57,8 @@ const FeatureList = [
Svg: require('@site/static/img/one_stop.svg').default,
description: (
<>
提供从 FlinkSQL 开发调试到作业上线下线的运维监控及 OLAP 能力,使数仓建设及数据治理一体化。
提供从 FlinkSQL 开发调试到上线下线的运维监控及 SQL 的查询执行能力,使数仓建设及数据治理
一体化
</>
),
},
......@@ -64,7 +67,8 @@ const FeatureList = [
Svg: require('@site/static/img/easy_of_extend.svg').default,
description: (
<>
SPI 插件化机制及各种设计模式支持用户快速扩展新功能,如数据源、报警方式、自定义语法等
源码采用 SPI 插件化及各种设计模式支持用户快速扩展新功能,如连接器、数据源、报警方式、
Flink CatalogCDC 整库同步、自定义 FlinkSQL 语法等
</>
),
},
......@@ -73,7 +77,8 @@ const FeatureList = [
Svg: require('@site/static/img/no_invasion.svg').default,
description: (
<>
Spring Boot 轻应用快速部署,不依赖 Hadoop 等外部环境,无感知连接和监控 Flink 集群
Spring Boot 轻应用快速部署,不需要在任何 Flink 集群修改源码或添加额外插件,无感知连接和
监控 Flink 集群
</>
),
},
......
......@@ -148,6 +148,7 @@
position: relative;
width:100%;
height: 20%;
padding-left: 80px;
}
.container .desc .desc_right img .fly_svg{
width:100%;
......
......@@ -33,36 +33,36 @@ function HomepageHeader() {
<div className="container">
<div className="desc">
<div className="desc_left">
<h1 className="hero__title">{siteConfig.title}</h1>
<p className="hero__subtitle">{siteConfig.tagline}</p>
<p className="hero_desc"> &nbsp;&nbsp;&nbsp;&nbsp;
一站式 FlinkSQL & SQL DataOps <br/>
基于 Apache Flink 二次开发,无侵入,开箱即用<br/>&nbsp;&nbsp;&nbsp;&nbsp;
实时即未来,批流为一体<br/><br/>
<h1 className="hero__title">{siteConfig.title}</h1>
<p className="hero__subtitle">{siteConfig.tagline}</p>
<p className="hero_desc"> &nbsp;&nbsp;&nbsp;&nbsp;
一站式 FlinkSQL & SQL DataOps <br/>
基于 Apache Flink 二次开发,无侵入,开箱即用<br/>&nbsp;&nbsp;&nbsp;&nbsp;
实时即未来,批流为一体<br/><br/>
</p>
<div className={styles.buttons}>
<Link
className="button button--secondary button--lg"
style={{borderRadius: '2rem', border: '1px solid #42b983'}}
to="https://github.com/DataLinkDC/dlink">
GitHub
</Link>
&nbsp;&nbsp;
<Link
className="button button--secondary button--lg"
style={{borderRadius: '2rem', border: '1px solid #42b983'}}
to="https://gitee.com/mirrors/Dlink">
Gitee
</Link>
&nbsp;&nbsp;
<Link
className="button button--secondary button--lg"
style={{backgroundColor: '#42b983', borderRadius: '2rem', border: '1px solid #42b983'}}
to="/docs/intro">
Quick Start
</Link>
&nbsp;&nbsp;
<span className={styles.indexCtasGitHubButtonWrapper}>
<div className={styles.buttons}>
<Link
className="button button--secondary button--lg"
style={{borderRadius: '2rem', border: '1px solid #42b983'}}
to="https://github.com/DataLinkDC/dlink">
GitHub
</Link>
&nbsp;&nbsp;
<Link
className="button button--secondary button--lg"
style={{borderRadius: '2rem', border: '1px solid #42b983'}}
to="https://gitee.com/mirrors/Dlink">
Gitee
</Link>
&nbsp;&nbsp;
<Link
className="button button--secondary button--lg"
style={{backgroundColor: '#42b983', borderRadius: '2rem', border: '1px solid #42b983'}}
to="/docs/intro">
Quick Start
</Link>
&nbsp;&nbsp;
<span className={styles.indexCtasGitHubButtonWrapper}>
<iframe
className={styles.indexCtasGitHubButton}
src="https://ghbtns.com/github-btn.html?user=DataLinkDC&amp;repo=dlink&amp;type=star&amp;count=true&amp;size=large"
......@@ -74,7 +74,7 @@ function HomepageHeader() {
</div>
</div>
<div className="desc_right">
<img src="home_logo.svg" className="fly_svg"></img>
<img src="home.png" className="fly_svg"></img>
</div>
</div>
</div>
......
This source diff could not be displayed because it is too large. You can view the blob instead.
<svg t="1649041845899" class="icon" viewBox="0 0 1024 1024" version="1.1"
xmlns="http://www.w3.org/2000/svg" p-id="1338" width="1200" height="500"
>
<defs>
<style type="text/css">@font-face { font-family: feedback-iconfont; src: url("//at.alicdn.com/t/font_1031158_u69w8yhxdu.woff2?t=1630033759944") format("woff2"), url("//at.alicdn.com/t/font_1031158_u69w8yhxdu.woff?t=1630033759944") format("woff"), url("//at.alicdn.com/t/font_1031158_u69w8yhxdu.ttf?t=1630033759944") format("truetype"); }
</style>
</defs>
<path d="M440.32 552.96c-30.72 0-51.2-20.48-76.8-30.72-76.8-40.96-143.36-92.16-204.8-153.6-20.48-25.6-46.08-46.08-61.44-76.8 20.48-10.24 46.08-5.12 66.56-10.24 5.12 0 10.24 5.12 10.24 5.12 81.92 102.4 174.08 184.32 266.24 266.24z" fill="#00A7EB" opacity=".29" p-id="1339">
<animateMotion path="M -500,0 c100,60 100,-50 200,0 c100,50 100,0 300,0" begin="0.5s" dur="1.5s" />
</path>
<path d="M936.96 353.28h-30.72c-40.96 0-81.92-5.12-117.76-35.84-40.96-35.84-92.16-25.6-128 5.12-15.36 15.36-30.72 30.72-40.96 46.08-10.24 5.12-15.36-10.24-20.48-15.36-30.72-35.84-66.56-76.8-102.4-112.64-40.96-35.84-92.16-66.56-143.36-81.92-51.2-10.24-102.4-25.6-148.48-40.96-5.12 0-10.24-5.12-20.48 0l30.72 76.8c0 5.12 0 10.24 5.12 10.24 5.12 25.6 15.36 46.08 25.6 66.56 10.24 25.6 25.6 56.32 40.96 81.92 40.96 71.68 92.16 138.24 148.48 199.68l5.12 5.12c15.36 5.12 10.24 15.36 0 25.6-71.68 102.4-133.12 209.92-184.32 332.8-15.36 25.6-25.6 56.32-35.84 87.04 10.24-10.24 15.36-20.48 20.48-30.72 71.68-117.76 143.36-235.52 271.36-296.96 35.84-15.36 66.56-30.72 102.4-51.2 30.72-15.36 61.44-35.84 81.92-61.44 25.6-20.48 35.84-51.2 46.08-81.92 10.24-35.84 30.72-66.56 61.44-87.04 51.2-25.6 107.52-25.6 163.84-30.72 10.24 0 25.6 5.12 35.84-5.12-25.6-5.12-46.08-5.12-66.56-5.12z" fill="#00A7EB" p-id="1340">
<animateMotion path="M -500,0 c100,60 100,-50 200,0 c100,50 100,0 300,0" begin="0.5s" dur="1.5s" />
</path>
<path d="M322.56 399.36c-25.6-40.96-51.2-87.04-76.8-128-5.12-20.48-15.36-40.96-25.6-66.56 0 0-5.12-5.12-5.12-10.24-25.6 0-51.2-5.12-76.8-5.12-5.12 0-10.24-5.12-15.36 0-5.12 5.12 0 10.24 0 15.36 15.36 25.6 30.72 51.2 40.96 76.8l10.24 10.24c51.2 66.56 112.64 122.88 174.08 184.32 30.72 25.6 61.44 56.32 92.16 76.8-40.96-51.2-81.92-97.28-117.76-153.6z" fill="#00A7EB" opacity=".54" p-id="1341">
<animateMotion path="M -500,0 c100,60 100,-50 200,0 c100,50 100,0 300,0" begin="0.5s" dur="1.5s" />
</path>
<defs>
<clipPath id="clipPath5">
<text x="-250" y="50" style="font-size: 100px;" text-anchor="middle" font-family="Verdana">
Dinky
</text>
</clipPath>
</defs>
</svg>
\ No newline at end of file
This source diff could not be displayed because it is too large. You can view the blob instead.
<?xml version="1.0" standalone="no"?><!DOCTYPE svg PUBLIC "-//W3C//DTD SVG 1.1//EN" "http://www.w3.org/Graphics/SVG/1.1/DTD/svg11.dtd">
<svg t="1649041845899" class="icon" viewBox="0 0 1024 1024" version="1.1" xmlns="http://www.w3.org/2000/svg" p-id="1338"
width="32" height="32"><defs><style type="text/css">@font-face { font-family: feedback-iconfont; src: url("//at.alicdn.com/t/font_1031158_u69w8yhxdu.woff2?t=1630033759944") format("woff2"), url("//at.alicdn.com/t/font_1031158_u69w8yhxdu.woff?t=1630033759944") format("woff"), url("//at.alicdn.com/t/font_1031158_u69w8yhxdu.ttf?t=1630033759944") format("truetype"); }
</style></defs><path d="M440.32 552.96c-30.72 0-51.2-20.48-76.8-30.72-76.8-40.96-143.36-92.16-204.8-153.6-20.48-25.6-46.08-46.08-61.44-76.8 20.48-10.24 46.08-5.12 66.56-10.24 5.12 0 10.24 5.12 10.24 5.12 81.92 102.4 174.08 184.32 266.24 266.24z" fill="#00A7EB" opacity=".29" p-id="1339"></path><path d="M936.96 353.28h-30.72c-40.96 0-81.92-5.12-117.76-35.84-40.96-35.84-92.16-25.6-128 5.12-15.36 15.36-30.72 30.72-40.96 46.08-10.24 5.12-15.36-10.24-20.48-15.36-30.72-35.84-66.56-76.8-102.4-112.64-40.96-35.84-92.16-66.56-143.36-81.92-51.2-10.24-102.4-25.6-148.48-40.96-5.12 0-10.24-5.12-20.48 0l30.72 76.8c0 5.12 0 10.24 5.12 10.24 5.12 25.6 15.36 46.08 25.6 66.56 10.24 25.6 25.6 56.32 40.96 81.92 40.96 71.68 92.16 138.24 148.48 199.68l5.12 5.12c15.36 5.12 10.24 15.36 0 25.6-71.68 102.4-133.12 209.92-184.32 332.8-15.36 25.6-25.6 56.32-35.84 87.04 10.24-10.24 15.36-20.48 20.48-30.72 71.68-117.76 143.36-235.52 271.36-296.96 35.84-15.36 66.56-30.72 102.4-51.2 30.72-15.36 61.44-35.84 81.92-61.44 25.6-20.48 35.84-51.2 46.08-81.92 10.24-35.84 30.72-66.56 61.44-87.04 51.2-25.6 107.52-25.6 163.84-30.72 10.24 0 25.6 5.12 35.84-5.12-25.6-5.12-46.08-5.12-66.56-5.12z" fill="#00A7EB" p-id="1340"></path><path d="M322.56 399.36c-25.6-40.96-51.2-87.04-76.8-128-5.12-20.48-15.36-40.96-25.6-66.56 0 0-5.12-5.12-5.12-10.24-25.6 0-51.2-5.12-76.8-5.12-5.12 0-10.24-5.12-15.36 0-5.12 5.12 0 10.24 0 15.36 15.36 25.6 30.72 51.2 40.96 76.8l10.24 10.24c51.2 66.56 112.64 122.88 174.08 184.32 30.72 25.6 61.44 56.32 92.16 76.8-40.96-51.2-81.92-97.28-117.76-153.6z" fill="#00A7EB" opacity=".54" p-id="1341"></path></svg>
\ No newline at end of file
......@@ -12,6 +12,7 @@ Dinky 基于 Apache Flink 进行扩展 ,增强 Flink 的应用与体验,探
最后,Dinky 的发展皆归功于 Apache Flink 等其他优秀的开源项目的指导与成果。
## 由来
Dinky(原 Dlink):
1.Dinky 英译为 “ 小巧而精致的 ” ,最直观的表明了它的特征:轻量级但又具备复杂的大数据开发能力。
......@@ -26,22 +27,17 @@ Dinky(原 Dlink):
其主要目标如下:
- 沉浸式 FlinkSQL 和 SQL 的数据开发平台:
自动提示补全、语法高亮、语句美化、语法校验、调试执行、执行计划、MetaStore、血缘分析、版本对比等
- 支持多版本的 FlinkSQL 作业各种提交方式:
Local、Standalone、Yarn/Kubernetes Session、Yarn Per-Job、Yarn/Kubernetes Application
- 支持 Apache Flink 所有原生及扩展的 Connector、UDF、CDC 等
- 支持 FlinkSQL 语法增强:
兼容 Apache Flink SQL、表值聚合函数、全局变量、执行环境、语句合并、整库同步、共享会话等
- 支持易扩展的 SQL 作业:
ClickHouse、Doris、Hive、Mysql、Oracle、Phoenix、PostgreSql、SqlServer 等
- 支持 FlinkCDC(Source 合并)整库实时入仓入湖
- 支持实时调试预览 Table 和 ChangeLog 数据及 Charts 图形展示
- 支持 Flink 元数据、数据源元数据查询及管理
- 支持实时任务运维:
上线下线、作业信息、集群信息、作业快照、异常信息、数据地图、数据探查、历史版本、报警记录等
- 沉浸式 FlinkSQL 数据开发:自动提示补全、语法高亮、语句美化、在线调试、语法校验、执行计划、MetaStore、血缘分析、版本对比等
- 支持 FlinkSQL 多版本开发及多种执行模式:Local、Standalone、Yarn/Kubernetes Session、Yarn Per-Job、Yarn/Kubernetes Application
- 支持 Apache Flink 生态:Connector、FlinkCDC、Table Store 等
- 支持 FlinkSQL 语法增强:表值聚合函数、全局变量、执行环境、语句合并、整库同步、共享会话等
- 支持 FlinkCDC 整库实时入仓入湖、多库输出、自动建表
- 支持 SQL 作业开发:ClickHouse、Doris、Hive、Mysql、Oracle、Phoenix、PostgreSql、SqlServer、StarRocks 等
- 支持实时在线调试预览 Table、 ChangeLog、统计图和 UDF
- 支持 Flink Catalog、数据源元数据在线查询及管理
- 支持实时任务运维:上线下线、作业信息、集群信息、作业快照、异常信息、数据地图、数据探查、历史版本、报警记录等
- 支持作为多版本 FlinkSQL Server 以及 OpenApi 的能力
- 支持易扩展的实时作业报警及报警组:钉钉、微信企业号、飞书、邮箱等
- 支持完全托管的 SavePoint/CheckPoint 启动及触发机制:最近一次、最早一次、指定一次等
- 支持实时作业报警及报警组:钉钉、微信企业号、飞书、邮箱等
- 支持自动托管的 SavePoint/CheckPoint 恢复及触发机制:最近一次、最早一次、指定一次等
- 支持多种资源管理:集群实例、集群配置、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