问题: 慢查询 搜索平台的公共集群,由于业务众多,对业务的es查询语法缺少约束,导致问题频发。业务可能写了一个…
分析和解决ElasticSearch数据同步丢失问题
背景 给普惠顺风车和打车使用的匹配引擎,他数据同步使用的是搜索dump引擎,dump引擎用flink程序消费往…
ElasticSearch分片内部原理
以下内容需要具备搜索引擎和elastic search的基础知识,了解什么是倒排索引,什么是es的数据节点,e…
Java的Jar包冲突的总结和实践
“我这边现在有个问题,兵哥,你忙吗,想找你看看,有关冲突的,等等我联系下你”,这天接到线上求助。一般情况下ja…
如何用java.io.*写一个服务器
写一个服务器 最近在看java nio相关的东西,照着书上的代码写了一个示例,然后就遇到了问题。为什么我们的服…
CPU异常问题排查
背景 距离上次排查cpu异常问题已经过去了至少5年了,那个时候刚接触Java就遇到了hashmap导致的cpu…
又一起GC问题排查过程
背景 继上次找到redis导致的gc问题之后,又有一个应用发生了gc时间长的问题。每次gc的大概1s的停顿时间…
生产FullGC问题排查
FullGC时间过长 问题 突然来了一波gc时间过长的告警,类似下面这个,接着接二连三的来了很多…
flink读取kafka数据未能触发watermark
过年被病毒闹的出不了门,就顺带着把flink秒级统计的逻辑写了一下,逻辑很简单,就是从kafka消费数据,然后…
flink使用时间戳作为起始offset消费kafka的问题
代码如下 private static voidtest2()throwsException { En…