01
Dinky进行作业参数配置
set 'execution.savepoint.ignore-unclaimed-state' = 'true';
代码写完以后不着急启动,直接点击发布按钮,就可以将代码替换成最新版本,然后回到作业运维版本进行代码重启;
这或许是一个对你有用的开源项目,data-warehouse-learning 项目是一套基于 MySQL + Kafka + Hadoop + Hive + Dolphinscheduler + Doris + Seatunnel + Paimon + Hudi + Iceberg + Flink + Dinky + DataRT + SuperSet 实现的实时离线数仓(数据湖)系统,以大家最熟悉的电商业务为切入点,详细讲述并实现了数据产生、同步、数据建模、数仓(数据湖)建设、数据服务、BI报表展示等数据全链路处理流程。
https://gitee.com/wzylzjtn/data-warehouse-learning
https://github.com/Mrkuhuo/data-warehouse-learning
https://bigdatacircle.top/
项目演示:
02
Dinky重启Flink任务
03
Dinky如何回退版本
在数据开发版本右侧历史版本地方,可以选择之前的历史版本进行版本回退。
然后进行代码发布及任务重启等操作。
04
代码获取
https://gitee.com/wzylzjtn/data-warehouse-learning
https://github.com/Mrkuhuo/data-warehouse-learning
05
文档获取
06
进交流群群添加作者