logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

生产事故:flink任务造成kafka连接泄漏导致kafka集群挂了!!!

1、问题背景为保障系统大促期间稳定运行,计划进行全链路生产压测。2、问题现象1》压测期间产生大量事后数据流向flink实时计算环节,flink任务消费的kafka出现堆积而产生告警。2》通过flink监控平台查看日志发现flink任务频繁重启失败,checkpoint save失败。3》通过kafka平台监控发现,flink任务连接kafka的连接数不断攀升,即kafka连接泄漏。4》短时间内所有

#kafka#flink#java +1
java虚拟机学习笔记之class文件检验器

<br />在编写java程序的时候,使用的API类不正确,引用的自定义类的包路径不正确以及定义的变量不存在或者不正确等等,在这个时候,对于Eclipse这样的IDE工具在保存的时候会显示错误,表示在.java文件编译成以.class时发生的编译错误而不能生产正确的class文件。<br /> <br />但是正确的编译成class文件就一定可以了吗?当然对于我们这样的学习的朋友来说没什么问题,如

#虚拟机#java
java虚拟机学习笔记之垃圾收集(上)

java程序是运行在java虚拟机当中的,在java虚拟机的堆中运行着程序所创建的对象。可以使用new,newarray,anewarray,multianewarray指令来创建对象,但是没有明确的代码来释放这些对象所使用的空间。垃圾收集就是自动释放不在被程序使用的对象的过程。为了能够无限制的使用内存,大部分的java虚拟机都附带有垃圾收集堆。★为什么使用使用垃圾收集垃圾收集,也就是把程序中不需

#虚拟机#java
到底了