Dinky 是一個(gè)開箱即用的一站式實(shí)時(shí)計(jì)算平臺(tái)，以 Apache Flink 為基礎(chǔ)，連接 OLAP 和數(shù)據(jù)湖等眾多框架，致力于流批一體和湖倉(cāng)一體的建設(shè)與實(shí)踐。

功能特點(diǎn)

其主要功能如下：

1、沉浸式 FlinkSQL 數(shù)據(jù)開發(fā)：自動(dòng)提示補(bǔ)全、語(yǔ)法高亮、語(yǔ)句美化、在線調(diào)試、語(yǔ)法校驗(yàn)、執(zhí)行計(jì)劃、MetaStore、血緣分析、版本對(duì)比等

2、支持 FlinkSQL 多版本開發(fā)及多種執(zhí)行模式：Local、Standalone、Yarn/Kubernetes Session、Yarn Per-Job、Yarn/Kubernetes Application

3、支持 Apache Flink 生態(tài)：Connector、FlinkCDC、Table Store 等

4、支持 FlinkSQL 語(yǔ)法增強(qiáng)：整庫(kù)同步、執(zhí)行環(huán)境、全局變量、語(yǔ)句合并、表值聚合函數(shù)等

5、支持 FlinkCDC 整庫(kù)實(shí)時(shí)入倉(cāng)入湖、多庫(kù)輸出、自動(dòng)建表

6、支持 SQL 作業(yè)開發(fā)：ClickHouse、Doris、Hive、Mysql、Oracle、Phoenix、PostgreSql、Presto、SqlServer、StarRocks 等

7、支持實(shí)時(shí)在線調(diào)試預(yù)覽 Table、 ChangeLog、Charts 和 UDF

8、支持 Flink Catalog、數(shù)據(jù)源元數(shù)據(jù)在線查詢及管理

9、支持實(shí)時(shí)任務(wù)運(yùn)維：上線下線、作業(yè)信息、集群信息、作業(yè)快照、異常信息、數(shù)據(jù)地圖、數(shù)據(jù)探查、歷史版本、報(bào)警記錄等

10、支持作為多版本 FlinkSQL Server 以及 OpenApi 的能力

11、支持實(shí)時(shí)作業(yè)報(bào)警及報(bào)警組：釘釘、微信企業(yè)號(hào)、飛書、郵箱等

12、支持自動(dòng)托管的 SavePoint/CheckPoint 恢復(fù)及觸發(fā)機(jī)制：最近一次、最早一次、指定一次等

13、支持多種資源管理：集群實(shí)例、集群配置、Jar、數(shù)據(jù)源、報(bào)警組、報(bào)警實(shí)例、文檔、全局變量、系統(tǒng)配置等

14、支持企業(yè)級(jí)管理：多租戶、用戶、角色、項(xiàng)目空間

15、更多隱藏功能等待小伙伴們探索

更新內(nèi)容

新特性

支持從最新完成的 checkpoint 恢復(fù)

修復(fù)

修復(fù) Flink SQL 歷史版本切換按鈕不起作用的問題

修復(fù)頁(yè)面不斷刷新的問題

修復(fù)兩個(gè)具有相同前綴的 Flink 配置項(xiàng)導(dǎo)致 Flink 配置解析出錯(cuò)的問題

修復(fù)創(chuàng)建新任務(wù)時(shí)前端表單被清空的問題

將helm的配置與 src/main/resources 目錄進(jìn)行同步

修復(fù)兩個(gè)前綴相同的 Flink 配置項(xiàng)導(dǎo)致 Flink 配置解析出錯(cuò)的問題

修復(fù) Paimon 查詢中數(shù)組類型未顯示值的問題

修復(fù) metadata-hive MissingFormatArgumentException

修復(fù)實(shí)用工具類中的導(dǎo)入錯(cuò)誤并解決與前端顯示相關(guān)的配置問題

修復(fù)數(shù)據(jù)源中心 Paimon 的 tinyint 數(shù)據(jù)不能預(yù)覽

修復(fù)flinkjar任務(wù)歷史緩存對(duì)比錯(cuò)誤

修復(fù) websocket 重連導(dǎo)致頁(yè)面閃爍

修復(fù)登錄頁(yè)初始化請(qǐng)求加載多次

優(yōu)化

在啟動(dòng) Flink 會(huì)話之前檢查集群是否已禁用

優(yōu)化 WebSocket 以實(shí)現(xiàn)異步發(fā)送