首页
学习
活动
专区
工具
TVP
发布

stream process

专栏作者
76
文章
92244
阅读量
15
订阅数
flink on yarn部分源码解析
转发请注明原创地址:https://www.cnblogs.com/dongxiao-yang/p/9403427.html
sanmutongzi
2020-03-05
9880
flink on yarn 用户代码获取keytab本地文件和principal的方法
flink on yarn的情况下配置的keytab文件会根据每次yarn application 分配taskmanager的变化都是不一样的,在部分场景下用户代码也需要获得keytab文件在yarn上的本地路径,可以通过以下方式拿到文件地址。
sanmutongzi
2020-03-04
8870
flink on yarn部分源码解析 (FLIP-6 new mode)
我们在https://www.cnblogs.com/dongxiao-yang/p/9403427.html文章里分析了flink提交single job到yarn集群上的代码,flink在1.5版
sanmutongzi
2020-03-04
8580
flink 问题记录
转发请注明原创地址:http://www.cnblogs.com/dongxiao-yang/p/7652337.html
sanmutongzi
2020-03-04
7100
kafka leader 服务器均衡。
Whenever a broker stops or crashes leadership for that broker's partitions transfers to other replicas. This means that by default when the broker is restarted it will only be a follower for all its partitions, meaning it will not be used for client reads and writes.
sanmutongzi
2020-03-04
5940
xargs 参数
hadoop fs -ls /source/recommend/at_access | awk -F "/" '{print $NF}' | grep -v $(date +%Y%m%d) | grep -v F | xargs -i sh press_by_handler.sh {} recommend/at_access,200,5
sanmutongzi
2020-03-04
1.3K0
布隆过滤器的java实现
private static final int DEFAULT_SIZE = 2 << 29;//布隆过滤器的比特长度
sanmutongzi
2020-03-04
9090
没有更多了
社区活动
腾讯技术创作狂欢月
“码”上创作 21 天,分 10000 元奖品池!
Python精品学习库
代码在线跑,知识轻松学
博客搬家 | 分享价值百万资源包
自行/邀约他人一键搬运博客,速成社区影响力并领取好礼
技术创作特训营·精选知识专栏
往期视频·千货材料·成员作品 最新动态
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档