Dinky 0.6.2 已发布,优化 Flink 应用体验

这篇具有很好参考价值的文章主要介绍了Dinky 0.6.2 已发布,优化 Flink 应用体验。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

Dinky 0.6.2 已发布,优化 Flink 应用体验

前言

Apache Flink 作为新一代的实时计算框架已经被应用到各个行业与领域,虽说应用程度不同,但都会遇到一些使用上的痛点,基础的应用痛点比如 FlinkSQL 作业提交不友好、作业无监控报警等。很大程度上说,FlinkSQL 大大加快了 Flink 的应用推广,而本文将简述开源项目 Dinky 如何改善 Flink 的痛点来优化 FlinkSQL 应用体验。

简介

实时即未来,Dlink 为 Apache Flink 而生,让 Flink SQL 纵享丝滑,并致力于实时计算平台建设。

Dinky 基于 Apache Flink 实现 Dlink ,增强 Flink 的应用与体验,探索流式数仓。即站在巨人肩膀上创新与实践,Dinky 在未来批流一体的发展趋势下潜力无限。

最后,Dinky 的发展皆归功于 Apache Flink 等其他优秀的开源项目的指导与成果。

特点

一个 开箱即用易扩展一站式 实时计算平台,以 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、数据源、报警组、报警实例、文档、用户、系统配置等
  • 更多隐藏功能等待小伙伴们探索

原理

Dinky 0.6.2 已发布,优化 Flink 应用体验

精彩瞬间

FlinkSQL Studio

Dinky 0.6.2 已发布,优化 Flink 应用体验

实时调试预览

Dinky 0.6.2 已发布,优化 Flink 应用体验

语法和逻辑检查

Dinky 0.6.2 已发布,优化 Flink 应用体验

JobPlan

Dinky 0.6.2 已发布,优化 Flink 应用体验

字段级血缘分析

Dinky 0.6.2 已发布,优化 Flink 应用体验

BI 展示

Dinky 0.6.2 已发布,优化 Flink 应用体验

元数据查询

Dinky 0.6.2 已发布,优化 Flink 应用体验

实时任务监控

Dinky 0.6.2 已发布,优化 Flink 应用体验

实时作业信息

Dinky 0.6.2 已发布,优化 Flink 应用体验

数据地图

Dinky 0.6.2 已发布,优化 Flink 应用体验

数据源注册

Dinky 0.6.2 已发布,优化 Flink 应用体验

优化 Flink 体验

沉浸式的 FlinkSQL IDE

Apache Flink 提供了 sql-client,但 sql-client 仅作为一个 beta 的功能,难以被应用到生产中。

Dinky 提供了沉浸式的 FlinkSQL IDE 开发能力,提供了自动提示与补全、语法高亮、语句美化、语法校验和逻辑检查、调试预览结果、字段级血缘分析等专业的功能,使 FlinkSQL 的开发如同 SQL 开发一样舒适与简单。

极易用的任务构建方式

Flink 在构建 FlinkSQL Jar 任务时通常需要考虑依赖及版本的维护、代码的编写、繁琐的编译打包过程等。

Dinky 将 FlinkSQL 任务的构建进行了极简,开发人员只需要专注 FlinkSQL 的口径书写,并且可以实时进行检查与调试,在任务提交的过程则是快速的自动化托管,以实现一个 FlinkSQL 语句可以在所有的执行模式与外部集群上随意切换。

对于 Dinky 来说,主要划分两类用户。一类是平台运维人员,该人员需要根据官网文档及自身的 Flink 知识储备来手动搭建稳定的 Dinky 运作环境,门槛较高;另一类是数据开发任务,即 SQL Boy,boys 只需熟悉 FlinkSQL 的语法与常见的应用场景,即可快速高效地进行 FlinkSQL 的开发与运维,达到易用的任务构建方式。这也是最符合企业生产团队的分工策略,平台和开发分离。

无侵入的部署模式

一些开源项目或自建平台通常需要绑死 Flink 集群或者侵入 Flink 的源码,容易 Flink 功能受限或在搭建和后续扩展时出现问题。

Dinky 则是完全无侵入,可部署与各个集群之外,同时连接和监控多个集群。轻易地对接各个版本的 Flink 集群与公司内仓库分支优化过的 Flink 集群,完全兼容 Flink 自身的 connector、udf、cdc 等。

增强式的功能体验

一些开源项目及自建平台一般只专注于 Flink 任务的提交与运维。

Dinky 则不同,为更舒适地使用 Flink 的相关功能进行的功能增强,如表值聚合函数、全局变量、CDC多源合并、执行环境、语句合并、共享会话等,并且还在不断地扩展新的功能增强,以使 Flink 更贴近企业的需求。

实时的监控报警

Dinky 提供实时的监控报警能力,实时守护已上线的流或批任务,在任务触发异常停止和成功完成时都会实时报警通知,并且记录了外部集群实时的任务信息,摆脱 History Server 的限制,弥补 deploy 的集群作业失败后信息难查询的不足,用户随时随地都可追溯历史作业的执行信息与异常。

一站式的开发运维

Dinky 提供了一站式的开发运维能力,从 FlinkSQL 开发调试到作业上线下线的运维监控,再到数据源的 OLAP 及普通查询能力等,使得数仓建设或数据治理过程中所有的工作均可以在 Dinky 上完成。

易扩展的代码实现

Dinky 非常注重代码的扩展能力,在源码中大量使用了 SPI 机制来支持用户低成本地自定义扩展新功能,比如数据源、报警方式、自定义语法等扩展。

Dinky 的功能体验也十分注重扩展能力,在功能设计上尽可能地开放了最大的配置能力,如自定义提示与补全语法、自定义数据源的Flink 配置与生成规则、自定义全局变量、自定义Flink执行环境、自定义集群配置的各种配置项等等。

Dinky 的外部对接也很注重扩展能力,基于 SpringBoot 的代码的高内聚和低耦合以及提供多种规范的 OpenAPI 使其可以很方便地扩展第三方生态、微服务或者平台,例如海豚调度等。

小而美的产品形态

常规的大数据平台或者开源项目一般是十分庞大的,维护成本较高。

正如 Dinky 本名所释,小巧而精美,一直是开源项目建设的首要目标。小巧具体指易搭建、不绑定任何外部中间件或文件系统、代码简洁易维护;精美则指沉浸式的页面、经过打磨的各种功能等。

近期计划

多租户及命名空间

Dinky 目前需要一个多租户的能力来分离业务数据及资源队列,需要命名空间来增强和规范代码业务逻辑的实现与扩展。

全局血缘与影响分析

Dinky 目前需要将所有的字段级血缘进行存储,以构建全局的血缘和影响分析,方便用户更容易地追溯数据问题。

统一元数据管理

Dinky 目前需要统一的元数据中心来管理外部数据源元数据,使其可以自动同步数据库物理模型与平台逻辑模型之间的结构,增强平台一站式的开发能力。

Flink 元数据持久化

Dinky 目前需要持久化 Flink Catalog,使作业开发时不再需要编写 CREATE TABLE 等语句,转变为可视化的元数据管理功能。

多版本 Flink-Client Server

Dinky 目前的 Flink 多版本支持需要启动多个不同版本的实例来支持。未来需要实现客户端与服务端分离,单独实现多版本的 Server。

整库千表同步

数据库的整库同步是一个常见的场景,Dinky 未来将提供一个简短的 FlinkSQL 实现整库同步任务构建的能力。

感谢

站在巨人的肩膀上,Dinky 才得以诞生。对此我们对使用的所有开源软件及其社区表示衷心的感谢!我们也希望自己不仅是开源的受益者,也能成为开源的贡献者,也希望对开源有同样热情和信念的伙伴加入进来,一起为开源献出一份力!致谢列表如下:

Apache Flink

Apache Dolphinscheduler

Ant-Design-Pro

Mybatis Plus

Monaco Editor

SpringBoot

用户评语

用户一

随着大数据实时领域的快速发展且逐渐向 SQL 化转移 ,作为新一代的 FlinkSQL Studio Dinky 应运而生 ,Dinky 作为一款 FlinkSQL 的交互式开发平台, 真正解决了目前 FinkSQL 的痛点 ,降低了开发运维的门槛,从 Dinky-0.1 到目前的 Dinky-0.6,我也见证了 Dinky 的成长 ,并基于 0.6 版本扩展了 Hive 元数据管理功能,这里还是要得力于 Dinky 的作者对整体平台的架构的设计,轻松上手即可扩展相关功能,经过不断地迭代更新, Dinky 也已逐渐完善企业级应用场景 : 包括 <元数据管理> , <表/字段级血缘关系>, <运维中心> ,<告警中心> 等等 , 以上特性/功能为我们建设企业级实时平台节省了很大成本,且真正具备企业级能力特点的实时开发平台。
同时感谢社区的认可,让我正式成为了社区中的一员 ,作为 Dinky 的使用者, 我将及时反馈在使用过程中遇到的问题, 作为贡献者: 我将和 Dinky 一起共同进步 , 积极回馈 ,拥抱开源 热爱开源。
在此也祝愿 Dinky 越来越强 ,社区越来越强大,希望更多的大佬加入进来,和我们一起共建 Dinky 社区,让 Dinky 在开源社区越走越远,越飞越高 。

用户二

Dinky 作为基于 flink 二次开发的一款交互式开发平台,提供 web 方式的 FlinkSQL 开发编辑器、自动补全,任务启停、数据地图、运行日志信息查看、支持 yarn 和 k8s 集群部署等功能。部署方面实现轻量化,开箱即用,降低与原始数据集群耦合度,便于适配原有数据集群版本;开发方面,降低开发人员使用 flink 难度及运维复杂度。

个人曾想过开发类似 Dinky 这样小而精的数据平台,限于现实场景、技术理解深度,没能实现。Dinky 开源后,从部署到阅读源码进行探索,从中学习不少轻量、容易扩展实现方案的优秀思想,未来将尽个人能力为社区做一些力所能及的事。最后,感谢 Dinky 贡献者,秉承自由开源,共建共赢理念,将源码开源,让更多开发人员学习使用,在实际场景中产生价值。

用户三

接触 flink 以来,一直诟病自身带的 web 平台,一点不好用!偶然看到 dinky,试用了下,真的挺好用!

dinky 作为一款 flink 的交互式开发平台,可以帮助开发者更好,更快的开发出自己的 flink 作业,解决了用户的痛点。随着作者从 0.1 到 0.6 不断的完善

和升级,支持的功能也越来越多,例如: sql 语法高亮、自动补全、sql 逻辑校验、血缘分析、任务启停、元数据查看、状态监控、flink on k8s 支持等等,这些功能大大的提高了开发者的效率。其中支持 flink on k8s,更是我接触后发现的一大亮点。目前平台已被我司作为生产使用。

最后,感谢 Dinky 开发者和建设者,祝福 dinky 社区发展越来越好,致敬!

更多用户

整合了FlinkSQL API的开发。

功能很强大,尤其 SQL 提交到远程功能,缩短了开发jar的时间。

操作简单,运维方便,可以脱离 flinkwebui 实时管控JOB的运行情况、异常及时报警。

功能规划清晰,快速迭代。

灵活部署,与原有集群解耦合。

各种功能比较丰富,界面设计接近阿里实时计算平台。

页面设计简洁、代码架构合理、兼容性强。

页面提交sql,方便的集成各种flink集群和数据库。

简化实时开发步骤,提高实时开发效率。

易用功能全面,问题反馈及解决及时。

开箱即用,支持多数据源,有一站式开发的核心能力。

文章来源地址https://www.toymoban.com/news/detail-449941.html

到了这里,关于Dinky 0.6.2 已发布,优化 Flink 应用体验的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • Dinky: 实时即未来,让 Flink SQL 纵享丝滑--如何本地编译、运行

    实时即未来,Dinky 为 Apache Flink 而生,让 Flink SQL 纵享丝滑。 Dinky 是一个开箱即用、易扩展,以 Apache Flink 为基础,连接 OLAP 和数据湖等众多框架的一站式实时计算平台,致力于流批一体和湖仓一体的探索与实践。 最后,Dinky 的发展皆归功于 Apache Flink 等其他优秀的开源项目的

    2024年02月09日
    浏览(34)
  • 基于 Dinky + FlinkSQL + Flink CDC 同步 MySQL 数据到 Elasticsearch、Kafka

    Dinky 是一个开箱即用的一站式实时计算平台以 Apache Flink 为基础,连接 OLAP 和数据湖等众多框架致力于流批一体和湖仓一体的建设与实践。本文以此为FlinkSQL可视化工具。 Flink SQL 使得使用标准 SQL 开发流式应用变得简单,免去代码开发。 Flink CDC 本文使用 MySQL CDC 连接器 允许从

    2024年02月16日
    浏览(35)
  • 记一次rax应用用户体验性能优化

    对于前端开发攻城狮们来说,性能优化是一个永恒的话题。随着前端需求复杂度的不断升高,在项目中想始终保持着良好的性能也逐渐成为了一个有挑战的事情。本次分享简述我们在 Rax 项目中常用的一些性能优化方式,并将从近期的一个实际业务需求出发,讲述我在 Rax C端

    2024年02月21日
    浏览(36)
  • Flink CDC 2.3 发布,持续优化性能,更多连接器支持增量快照,新增 Db2 支持

    01 Flink CDC 简介 Flink CDC  [ 1] 是基于数据库的日志 CDC 技术,实现了全增量一体化读取的数据集成框架。配合 Flink 优秀的管道能力和丰富的上下游生态,Flink CDC 可以高效实现海量数据的实时集成。 作为新一代的实时数据集成框架,Flink CDC 具有全增量一体化、无锁读取、并行读

    2024年02月01日
    浏览(29)
  • Flink 流处理应用性能优化指南

    作者:禅与计算机程序设计艺术 在数据处理过程中,作为流处理系统的 Apache Flink 是当前最热门的开源框架之一。相对于其他的一些框架(比如 Spark Streaming、Storm),Flink 提供了更高的计算效率、更低的延迟以及更灵活的数据处理能力。但是,由于其基于流处理模式而非批处

    2024年02月07日
    浏览(24)
  • 小程序发布体验版流程、发布正式版

    【注意】 如果使用的测试 appid 则【上传】按钮不能点击,必须使用真实 appid 上传成功后在 微信小程序公众平台 进行版本管理 点击下一步 点击“继续提交”,填写信息 点击 “提交审核” ↑ 提示 “当前提审的开发版本代码与隐私协议内容不匹配,请在当前提审页面,点击

    2023年04月25日
    浏览(56)
  • Flink快速部署集群,体验炸了!

    📢📢📢📣📣📣 哈喽!大家好,我是【IT邦德】,江湖人称jeames007,10余年DBA及大数据工作经验 一位上进心十足的【大数据领域博主】!😜😜😜 中国DBA联盟(ACDU)成员,目前服务于工业互联网 擅长主流Oracle、MySQL、PG、高斯及Greenplum运维开发,备份恢复,安装迁移,性能优

    2024年02月04日
    浏览(31)
  • 【Flink系列七】TableAPI和FlinkSQL初体验

    Apache Flink 有两种关系型 API 来做流批统一处理:Table API 和 SQL Table API 是用于 Scala 和 Java 语言的查询API,它可以用一种非常直观的方式来组合使用选取、过滤、join 等关系型算子。  Flink SQL 是基于 Apache Calcite 来实现的标准 SQL。无论输入是连续的(流式)还是有界的(批处理

    2024年02月03日
    浏览(28)
  • OpenAI 发布GPT-4——全网抢先体验

    最近 OpenAI 犹如开挂一般,上周才刚刚推出GPT-3.5-Turbo API,今天凌晨再次祭出GPT-4这个目前最先进的多模态预训练大模型。与上一代GPT3.5相比,GPT-4最大的飞跃是增加了识图能力,并且回答准确性也得到显著提高。GPT-4在多个专业和学术基准测试中展现出令人印象深刻的表现,有

    2024年02月02日
    浏览(40)
  • 更好的用户体验, 开源实时监控新版发布

    哈喽大家好,时间很快两个月又过去了,HertzBeat 经过近两个月的迭代终于发布了 v1.4.1 版本。为什么是终于,因为有点难哈哈。我们参考 rocketmq 重构了 netty 的 server client 端模块,重构了采集器集群调度。比起上一版本有了更优雅的通讯代码,更完善全面的集群。 采集任务一

    2024年02月07日
    浏览(27)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包