笔者目前在汽车之家云基础平台负责flink平台,数据湖, kafka平台的设计及开发。平时擅长做平台设计,定位及解决各种疑难杂症。最近开始冲动,想总结下最近几年使用的工具及定位的疑难杂症。时间久远,且目前工作,生活节奏较快。我大多数总结的文章应该都是大白话文,以简短的文章为主。心路历程及过程都是次要的, 主要就是短!!!
现在介绍第一个'短文',使用 arthas 做代码热更新
-
下载 arthas
wget https://arthas.aliyun.com/arthas-boot.jar java -jar arthas-boot.jar
-
启动arthas并选择attach的进程
java -jar arthas-boot.jar
-
反编译某个类文件
>>>jad --source-only org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl > /home/flink/code/SlotPoolImpl.java
-
修改/home/flink/code/SlotPoolImpl.java 文件
这个时候就吭哧瘪肚的加日志也好,改代码逻辑也好
-
sc 查找加载 你要装载的类的 classLoaderHash
\>>> sc -d *SlotPoolImpl | grep classLoaderHash
\>>> 18b4aac2
注意 第3,4步反编译不一定好使(部分语法编出来的文件不能用),最好跳过第2,3步把源码在 idea里面修改再拷贝到服务器最为稳妥
-
编译一遍新刚才修改的java文件
mc -c 18b4aac2 /home/flink/code/SlotPoolImpl.java -d /home/flink/code
这个时候就会重新生成 class 文件
/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.class
-
重新加载这个文件
\>>> redefine /home/flink/code/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.class
-
作用:
当时笔者修改flink1.9.2版本代码的时候漏掉了些逻辑,这个时候急于验证。就使用了arthas热更新功能,从修改代码到重新编译再到验证用了不到5分钟时间。快速的解决相应的问题