作者小头像 Lv.1
更多个人资料
20 成长值
0 关注
0 粉丝
+ 关注 私信

个人介绍

这个人很懒,什么都没有留下

感兴趣或擅长的领域

暂无数据
个人勋章
TA还没获得勋章~
成长雷达
20
0
0
0
0

个人资料

个人介绍

这个人很懒,什么都没有留下

感兴趣或擅长的领域

暂无数据

达成规则

以上满足项可达成此勋章

  • 博客
  • 关注
  • 粉丝
  • 论坛
全部时间
全部时间
最近三天
最近一周
最近一月
  • 全部
  • 暂无专栏分类
Flink 1.10内核源码梳理-client提交作业流程源码梳理
以flink1.10开源代码未例子。梳理flink client提交作业的源码流程 1、/bin/flink run xxx用户通过flink client的命令行工具提交作业flink只是个shell脚本,原理就是调用如下类 org.apache.flink.client.cli.CliFrontend “$@” 2、CliFrontend的main()函数内部逻辑getConfigura...
Flink
作者小头像 芳萌萌芳 2021-06-29 23:47:17
7904
0
0
2021-06-29 23:47:17
999+
0
0
【数据湖探索】FLINK 自定义jar作业配置checkppoint功能
## Flink 自定义作业配置checkppoint功能在Flink 自定义作业 Jar包代码中加入如下代码:  如下代码含义是以EXACTLY_ONCE模式,每隔40s 保存checkpoint 到obs的${bucket}桶中的jobs/checkpoint/my_jar路径。    其中最主要是的保存checkpoint路径,一般是将checkpoint存入obs桶中,路径格式如下:...
JAR 数据湖探索 DLI
作者小头像 芳萌萌芳 2020-12-31 10:44:17
8640
0
0
2020-12-31 10:44:17
999+
0
0
https://www.baidu.com/s?ie=utf-8&f=3&rsv_bp=0&rsv_idx=1&tn=baidu&wd=sed%20%E6%9B%BF%E6%8D%A2%E5%AD%97%E7%AC%A6%E4%B8%B2&rsv_pq=c7db61a600035dc5&rsv_t=5e19yEsbV9N5fIvdlGRU
作者小头像
作者小头像
快速交付
+ 关注