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
6881
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
7287
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
+ 关注