博客专栏推荐
-
1178062次
-
122395次
-
57058次
-
29515次
本月博客排行
年度博客排行
-
第1名
青否云后端云 -
第2名
zw7534313 -
第3名
大家都说我很棒 - liyihz2008
- wy_19921005
- hbxflihua
- gengyun12
- e_e
- luxurioust
- zysnba
- dbagirl
- itdatacenter
- alsmile
- robotmen
- jywhltj
- johnsmith9th
- gaozzsoft
- sichunli_030
- zhangdaiscott
- cpongo1
- chinahuyong
- fantaxy025025
- 淡看人生
- leslie26
- cuityang
- qepwqnp
- 解宜然
- jveqi
- mukeliang728
- hellohank
- gashero
- ssydxa219
- hanbaohong
- ranbuijj
- weiyides
- jickcai
- lzyfn123
- gdpglc
- appalese
- jackpot1234
- java-007
- gaojingsong
- wallimn
- lyongq04
- javashop
- xyuma
- zhangyi0618
- vipbooks
- avi
最新文章列表
1、多线程6种状态
public enum state {
//新建
new,
//运行
runnable,
//阻塞
blocked,
//等待
waiting,
//延时等待
timed_waiting,
...
有327人浏览
2020-04-08 17:52
众所周知 flink 是当前广泛使用的计算引擎，flink 使用 checkpoint 机制进行容错处理\[1\]，flink 的 checkpoint 会将状态快照备份到分布式存储系统，供后续恢复使用。在 alibaba 内部我们使用的存储主要是 hdfs，当同一个集群的 job 到达一定数量后，会对 hdfs 造成非常大的压力，本文将介绍一种大幅度降低 hdfs 压力的方法 -- 小文件合并。
...
有257人浏览
2020-01-17 14:18
public class nthread implements runnable {
static object o=new object();
volatile static int index=0;
static int n=10; //线程数量
int max=100; //打印次数
int i; //线程名
public nthread(int ...
有257人浏览
2020-01-09 13:33
分析痛点
----
笔者线上有一个 flink 任务消费 kafka 数据，将数据转换后，在 flink 的 sink 算子内部调用第三方 api 将数据上报到第三方的数据分析平台。这里使用批量同步 api，即：每 50 条数据请求一次第三方接口，可以通过批量 api 来提高请求效率。由于调用的外网接口，所以每次调用 api 比较耗时。假如批次大小为 50，且请求接口的平均响应时间为 50ms，使 ...
有343人浏览
2019-12-30 15:25
导读
--
> 世界上只有两种物质：高效率和低效率；世界上只有两种人：高效率的人和低效率的人。——萧伯纳
同理，世界上只有两种代码：高效代码 ...
有284人浏览
2019-12-27 15:57
« 上一页 1 …